public interface IMessageBus
MessageBusMessagingFactory
which ensures the interaction with the message bus.Modifier and Type | Method and Description |
---|---|
void |
attachDuplexInputChannels(IDuplexInputChannel serviceInputChannel,
IDuplexInputChannel clientInputChannel)
Attaches input channels which are used for the communication with the message bus.
|
Event<MessageBusClientEventArgs> |
clientConnected()
The event is raised when a client is connected to the service.
|
Event<MessageBusClientEventArgs> |
clientDisconnected()
The event is raised when a client is disconnected from the service.
|
void |
detachDuplexInputChannels()
Detaches input channels and stops the listening.
|
void |
disconnectService(java.lang.String serviceAddress)
Disconnect and unregisters the specified service.
|
java.lang.String[] |
getConnectedClients(java.lang.String serviceAddress)
Returns list of all clients connected to the specified service.
|
java.lang.String[] |
getConnectedServices()
Returns list of all connected services.
|
int |
GetNumberOfConnectedClients(java.lang.String serviceAddress)
Returns number of clients connected to the specified service.
|
Event<MessageBusMessageEventArgs> |
messageToClientSent()
The event is raised when a service sent a message to the client.
|
Event<MessageBusMessageEventArgs> |
messageToServiceSent()
The event is raised when a client sent a message to the service.
|
Event<MessageBusServiceEventArgs> |
serviceRegistered()
The event is raised when a new service is registered.
|
Event<MessageBusServiceEventArgs> |
serviceUnregistered()
The event is raised when a service is unregistered.
|
Event<MessageBusServiceEventArgs> serviceRegistered()
Event<MessageBusServiceEventArgs> serviceUnregistered()
Event<MessageBusClientEventArgs> clientConnected()
Event<MessageBusClientEventArgs> clientDisconnected()
Event<MessageBusMessageEventArgs> messageToServiceSent()
Event<MessageBusMessageEventArgs> messageToClientSent()
void attachDuplexInputChannels(IDuplexInputChannel serviceInputChannel, IDuplexInputChannel clientInputChannel) throws java.lang.Exception
serviceInputChannel
- input channel used by services.clientInputChannel
- input channel used by clients.java.lang.Exception
void detachDuplexInputChannels()
java.lang.String[] getConnectedServices()
java.lang.String[] getConnectedClients(java.lang.String serviceAddress)
serviceAddress
- id of the serviceint GetNumberOfConnectedClients(java.lang.String serviceAddress)
serviceAddress
- id of the servicevoid disconnectService(java.lang.String serviceAddress)
serviceAddress
- id of the service that shall be unregistered