|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objecteneter.messaging.messagingsystems.threadpoolmessagingsystem.ThreadPoolMessagingSystemFactory
public class ThreadPoolMessagingSystemFactory
Messaging system delivering messages asynchronously (when a message is received a separate thread is invoked to process it). Each incoming message is routed into its own thread from the pool. It means when a message is received the thread from the pool is taken and the message is notified.
Constructor Summary | |
---|---|
ThreadPoolMessagingSystemFactory()
Constructs the factory. |
|
ThreadPoolMessagingSystemFactory(IProtocolFormatter protocolFormatter)
Constructs the factory. |
Method Summary | |
---|---|
IDuplexInputChannel |
createDuplexInputChannel(java.lang.String channelId)
Creates the input channel which can receive and send messages to the output channel. |
IDuplexOutputChannel |
createDuplexOutputChannel(java.lang.String channelId)
Creates the output channel which can sends and receive messages from the input channel. |
IDuplexOutputChannel |
createDuplexOutputChannel(java.lang.String channelId,
java.lang.String responseReceiverId)
Creates the output channel which can sends and receive messages from the input channel. |
IThreadDispatcherProvider |
getInputChannelThreading()
Gets threading mode used for input channels. |
IThreadDispatcherProvider |
getOutputChannelThreading()
Gets threading mode used for output channels. |
ThreadPoolMessagingSystemFactory |
setInputChannelThreading(IThreadDispatcherProvider inputChannelThreading)
Sets threading mode for input channels. |
ThreadPoolMessagingSystemFactory |
setOutputChannelThreading(IThreadDispatcherProvider outputChannelThreading)
Sets threading mode for output channels. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ThreadPoolMessagingSystemFactory()
public ThreadPoolMessagingSystemFactory(IProtocolFormatter protocolFormatter)
protocolFormatter
- formatting of low-level messages between output and input channels.Method Detail |
---|
public IDuplexOutputChannel createDuplexOutputChannel(java.lang.String channelId) throws java.lang.Exception
IMessagingSystemFactory
createDuplexOutputChannel
in interface IMessagingSystemFactory
channelId
- address of the input channel.
java.lang.Exception
public IDuplexOutputChannel createDuplexOutputChannel(java.lang.String channelId, java.lang.String responseReceiverId) throws java.lang.Exception
IMessagingSystemFactory
createDuplexOutputChannel
in interface IMessagingSystemFactory
channelId
- address of the input channel.responseReceiverId
- unique identifier of the output channel. If the value is null then the identifier is genearated automatically
java.lang.Exception
public IDuplexInputChannel createDuplexInputChannel(java.lang.String channelId) throws java.lang.Exception
IMessagingSystemFactory
createDuplexInputChannel
in interface IMessagingSystemFactory
channelId
- address of the input channel.
java.lang.Exception
public ThreadPoolMessagingSystemFactory setInputChannelThreading(IThreadDispatcherProvider inputChannelThreading)
inputChannelThreading
- threading model
public IThreadDispatcherProvider getInputChannelThreading()
public ThreadPoolMessagingSystemFactory setOutputChannelThreading(IThreadDispatcherProvider outputChannelThreading)
outputChannelThreading
-
public IThreadDispatcherProvider getOutputChannelThreading()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |