eneter.messaging.endpoints.stringmessages
Class DuplexStringMessagesFactory

java.lang.Object
  extended by 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);
 
 


Constructor Summary
DuplexStringMessagesFactory()
           
 
Method Summary
 IDuplexStringMessageReceiver createDuplexStringMessageReceiver()
          Creates message receiver.
 IDuplexStringMessageSender createDuplexStringMessageSender()
          Creates message sender.
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DuplexStringMessagesFactory

public DuplexStringMessagesFactory()
Method Detail

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