public class DuplexStringMessagesFactory extends java.lang.Object implements IDuplexStringMessagesFactory
...
// 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);
...
...
// 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);
| Constructor and Description |
|---|
DuplexStringMessagesFactory() |
| Modifier and Type | Method and Description |
|---|---|
IDuplexStringMessageReceiver |
createDuplexStringMessageReceiver()
Creates message receiver.
|
IDuplexStringMessageSender |
createDuplexStringMessageSender()
Creates message sender.
|
public IDuplexStringMessageSender createDuplexStringMessageSender()
IDuplexStringMessagesFactorycreateDuplexStringMessageSender in interface IDuplexStringMessagesFactorypublic IDuplexStringMessageReceiver createDuplexStringMessageReceiver()
IDuplexStringMessagesFactorycreateDuplexStringMessageReceiver in interface IDuplexStringMessagesFactory