|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objecteneter.messaging.messagingsystems.websocketmessagingsystem.WebSocketMessagingSystemFactory
public class WebSocketMessagingSystemFactory
Messaging system delivering messages via websockets.
It creates the communication channels using WebSockets for sending and receiving messages.
The channel id must be a valid URI address. E.g.: ws://127.0.0.1:6080/MyService/.
Constructor Summary | |
---|---|
WebSocketMessagingSystemFactory()
Constructs the websocket messaging factory. |
|
WebSocketMessagingSystemFactory(IProtocolFormatter protocolFormatter)
Constructs the websocket messaging factory. |
Method Summary | |
---|---|
IDuplexInputChannel |
createDuplexInputChannel(java.lang.String channelId)
Creates the duplex input channel receiving messages from the duplex output channel and sending back response messages by using WebSocket. |
IDuplexOutputChannel |
createDuplexOutputChannel(java.lang.String channelId)
Creates the duplex output channel sending messages to the duplex input channel and receiving response messages by using WebSocket. |
IDuplexOutputChannel |
createDuplexOutputChannel(java.lang.String channelId,
java.lang.String responseReceiverId)
Creates the duplex output channel sending messages to the duplex input channel and receiving response messages by using WebSocket. |
IClientSecurityFactory |
getClientSecurity()
Gets the factory that is used for creation of client sockets. |
IThreadDispatcherProvider |
getInputChannelThreading()
Gets threading mode used for input channels. |
IThreadDispatcherProvider |
getOutputChannelThreading()
Gets threading mode used for output channels. |
int |
getPingFrequency()
Returns the ping frequency in milliseconds. |
IServerSecurityFactory |
getServerSecurity()
Gets the factory that is used for creation of server sockets. |
WebSocketMessagingSystemFactory |
setClientSecurity(IClientSecurityFactory clientSecurityFactory)
Sets the factory that will be used for creation of secured client socket. |
WebSocketMessagingSystemFactory |
setInputChannelThreading(IThreadDispatcherProvider inputChannelThreading)
Sets threading mode for input channels. |
WebSocketMessagingSystemFactory |
setOutputChannelThreading(IThreadDispatcherProvider outputChannelThreading)
Sets threading mode for output channels. |
WebSocketMessagingSystemFactory |
setPingFrequency(int milliseconds)
Sets frequency to send the websocket ping message. |
WebSocketMessagingSystemFactory |
setServerSecurity(IServerSecurityFactory serverSecurityFactory)
Sets the factory that will be used for creation of server sockets. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public WebSocketMessagingSystemFactory()
public WebSocketMessagingSystemFactory(IProtocolFormatter protocolFormatter)
protocolFormatter
- formatter used for low-level messages between output and input channels.Method Detail |
---|
public IDuplexOutputChannel createDuplexOutputChannel(java.lang.String channelId) throws java.lang.Exception
createDuplexOutputChannel
in interface IMessagingSystemFactory
channelId
- Identifies the receiving duplex input channel. The channel id must be a valid URI address e.g. ws://127.0.0.1:8090/MyService/
java.lang.Exception
public IDuplexOutputChannel createDuplexOutputChannel(java.lang.String channelId, java.lang.String responseReceiverId) throws java.lang.Exception
createDuplexOutputChannel
in interface IMessagingSystemFactory
channelId
- Identifies the receiving duplex input channel. The channel id must be a valid URI address e.g. ws://127.0.0.1:8090/responseReceiverId
- Identifies the response receiver of this duplex output channel.
java.lang.Exception
public IDuplexInputChannel createDuplexInputChannel(java.lang.String channelId) throws java.lang.Exception
createDuplexInputChannel
in interface IMessagingSystemFactory
channelId
- Identifies this duplex input channel. The channel id must be a valid URI address (e.g. ws://127.0.0.1:8090/MyService/) the input channel will listen to.
java.lang.Exception
public WebSocketMessagingSystemFactory setServerSecurity(IServerSecurityFactory serverSecurityFactory)
serverSecurityFactory
- public IServerSecurityFactory getServerSecurity()
public WebSocketMessagingSystemFactory setClientSecurity(IClientSecurityFactory clientSecurityFactory)
clientSecurityFactory
- public IClientSecurityFactory getClientSecurity()
public WebSocketMessagingSystemFactory setInputChannelThreading(IThreadDispatcherProvider inputChannelThreading)
inputChannelThreading
- threading model
public IThreadDispatcherProvider getInputChannelThreading()
public WebSocketMessagingSystemFactory setOutputChannelThreading(IThreadDispatcherProvider outputChannelThreading)
outputChannelThreading
-
public IThreadDispatcherProvider getOutputChannelThreading()
public WebSocketMessagingSystemFactory setPingFrequency(int milliseconds)
milliseconds
- frequency in milliseconds
public int getPingFrequency()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |