@Component public class Communication extends java.lang.Object implements PassengerMessaging, DriverMessaging
Constructor and Description |
---|
Communication(KafkaPassengerPublisher passengerPublisher,
KafkaDriverPublisher driverPublisher,
org.springframework.messaging.simp.SimpMessagingTemplate simpSender,
java.lang.String passengerWebSocketTopic,
java.lang.String driverWebSocketTopic,
Scheduler scheduler) |
Modifier and Type | Method and Description |
---|---|
void |
broadcastDriverSimulationEvent(WebsocketDriverEvent driverEvent)
notify to whoever is listening that there is a driver state change
|
void |
broadcastPassengerSimulationEvent(WebsocketPassengerEvent passengerEvent)
notify whoever is listening that there is a passenger state change
|
void |
incomingDriverEvent(OutboundDriverMessage message)
handle an event that was sent from application to the simulator
|
void |
incomingPassengerEvent(OutboundPassengerMessage message)
handle an event that was sent from application to the simulator
|
void |
outgoingDriverEvent(InboundDriverMessage message)
send an event to the application
|
void |
outgoingPassengerEvent(InboundPassengerMessage message)
send an event to the application
|
@Autowired public Communication(KafkaPassengerPublisher passengerPublisher, KafkaDriverPublisher driverPublisher, org.springframework.messaging.simp.SimpMessagingTemplate simpSender, @Value(value="${web-socket.topic.passenger}") java.lang.String passengerWebSocketTopic, @Value(value="${web-socket.topic.driver}") java.lang.String driverWebSocketTopic, Scheduler scheduler)
public void incomingPassengerEvent(OutboundPassengerMessage message)
PassengerMessaging
incomingPassengerEvent
in interface PassengerMessaging
public void incomingDriverEvent(OutboundDriverMessage message)
DriverMessaging
incomingDriverEvent
in interface DriverMessaging
public void outgoingPassengerEvent(InboundPassengerMessage message)
PassengerMessaging
outgoingPassengerEvent
in interface PassengerMessaging
public void outgoingDriverEvent(InboundDriverMessage message)
DriverMessaging
outgoingDriverEvent
in interface DriverMessaging
public void broadcastPassengerSimulationEvent(WebsocketPassengerEvent passengerEvent)
PassengerMessaging
broadcastPassengerSimulationEvent
in interface PassengerMessaging
public void broadcastDriverSimulationEvent(WebsocketDriverEvent driverEvent)
DriverMessaging
broadcastDriverSimulationEvent
in interface DriverMessaging
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.