Package net.engio.mbassy.bus.config
Class Feature.AsynchronousMessageDispatch
java.lang.Object
net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
- All Implemented Interfaces:
Feature
- Enclosing interface:
Feature
-
Nested Class Summary
Nested classes/interfaces inherited from interface net.engio.mbassy.bus.config.Feature
Feature.AsynchronousHandlerInvocation, Feature.AsynchronousMessageDispatch, Feature.SyncPubSub
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate ThreadFactory
protected static final ThreadFactory
private BlockingQueue
<IMessagePublication> private int
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic final Feature.AsynchronousMessageDispatch
Default()
int
setDispatcherThreadFactory
(ThreadFactory dispatcherThreadFactory) setMessageQueue
(BlockingQueue<IMessagePublication> pendingMessages) setNumberOfMessageDispatchers
(int numberOfMessageDispatchers)
-
Field Details
-
MessageDispatchThreadFactory
-
numberOfMessageDispatchers
private int numberOfMessageDispatchers -
messageQueue
-
dispatcherThreadFactory
-
-
Constructor Details
-
AsynchronousMessageDispatch
public AsynchronousMessageDispatch()
-
-
Method Details
-
Default
-
getNumberOfMessageDispatchers
public int getNumberOfMessageDispatchers() -
setNumberOfMessageDispatchers
public Feature.AsynchronousMessageDispatch setNumberOfMessageDispatchers(int numberOfMessageDispatchers) -
getMessageQueue
-
setMessageQueue
public Feature.AsynchronousMessageDispatch setMessageQueue(BlockingQueue<IMessagePublication> pendingMessages) -
getDispatcherThreadFactory
-
setDispatcherThreadFactory
public Feature.AsynchronousMessageDispatch setDispatcherThreadFactory(ThreadFactory dispatcherThreadFactory)
-