eneter.messaging.endpoints.stringmessages
Class DuplexStringMessagesFactory
java.lang.Object
eneter.messaging.endpoints.stringmessages.DuplexStringMessagesFactory
- All Implemented Interfaces:
- IDuplexStringMessagesFactory
public class DuplexStringMessagesFactory
- extends java.lang.Object
- implements IDuplexStringMessagesFactory
Implements the factory to create duplex string message sender and receiver.
The following example shows how to send a string message via TCP.
...
// Create string message sender.
IDuplexStringMessagesFactory aSenderFactory = new DuplexStringMessagesFactory();
IDuplexStringMessageSender aSender = aSenderFactory.createDuplexStringMessageSender();
// Subscribe to receive response messages.
aSender.responseReceived().subscribe(...);
// Create TCP messaging.
IMessagingSystemFactory aMessaging = new TcpMessagingSystemFactory();
IDuplexOutputChannel anOutputChannel = aMessaging.createDuplexOutputChannel("tcp://127.0.0.1:8033/");
// Attach output channel and be able to send messages and receive responses.
aSender.attachDuplexOutputChannel(anOutputChannel);
...
The following example shows how to receive a string message via TCP.
...
// Create string message receiver.
IDuplexStringMessagesFactory aReceiverFactory = new DuplexStringMessagesFactory();
IDuplexStringMessageReceiver aReceiver = aReceiverFactory.createDuplexStringMessageReceiver();
// Subscribe to receive messages.
aReceiver.requestReceived().subscribe(...);
// Create TCP messaging.
IMessagingSystemFactory aMessaging = new TcpMessagingSystemFactory();
IDuplexInputChannel anInputChannel = aMessaging.createDuplexInputChannel("tcp://127.0.0.1:8033/");
// Attach input channel and start listening to messages.
aReceiver.attachDuplexInputChannel(anInputChannel);
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DuplexStringMessagesFactory
public DuplexStringMessagesFactory()
createDuplexStringMessageSender
public IDuplexStringMessageSender createDuplexStringMessageSender()
- Description copied from interface:
IDuplexStringMessagesFactory
- Creates message sender.
- Specified by:
createDuplexStringMessageSender
in interface IDuplexStringMessagesFactory
- Returns:
- string message sender
createDuplexStringMessageReceiver
public IDuplexStringMessageReceiver createDuplexStringMessageReceiver()
- Description copied from interface:
IDuplexStringMessagesFactory
- Creates message receiver.
- Specified by:
createDuplexStringMessageReceiver
in interface IDuplexStringMessagesFactory
- Returns:
- string message receiver