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()
IDuplexStringMessagesFactory
createDuplexStringMessageSender
in interface IDuplexStringMessagesFactory
public IDuplexStringMessageReceiver createDuplexStringMessageReceiver()
IDuplexStringMessagesFactory
createDuplexStringMessageReceiver
in interface IDuplexStringMessagesFactory