Package net.engio.mbassy.bus.config
Class Feature.AsynchronousMessageDispatch
- java.lang.Object
-
- net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface net.engio.mbassy.bus.config.Feature
Feature.AsynchronousHandlerInvocation, Feature.AsynchronousMessageDispatch, Feature.SyncPubSub
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.ThreadFactory
dispatcherThreadFactory
protected static java.util.concurrent.ThreadFactory
MessageDispatchThreadFactory
private java.util.concurrent.BlockingQueue<IMessagePublication>
messageQueue
private int
numberOfMessageDispatchers
-
Constructor Summary
Constructors Constructor Description AsynchronousMessageDispatch()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static Feature.AsynchronousMessageDispatch
Default()
java.util.concurrent.ThreadFactory
getDispatcherThreadFactory()
java.util.concurrent.BlockingQueue<IMessagePublication>
getMessageQueue()
int
getNumberOfMessageDispatchers()
Feature.AsynchronousMessageDispatch
setDispatcherThreadFactory(java.util.concurrent.ThreadFactory dispatcherThreadFactory)
Feature.AsynchronousMessageDispatch
setMessageQueue(java.util.concurrent.BlockingQueue<IMessagePublication> pendingMessages)
Feature.AsynchronousMessageDispatch
setNumberOfMessageDispatchers(int numberOfMessageDispatchers)
-
-
-
Field Detail
-
MessageDispatchThreadFactory
protected static final java.util.concurrent.ThreadFactory MessageDispatchThreadFactory
-
numberOfMessageDispatchers
private int numberOfMessageDispatchers
-
messageQueue
private java.util.concurrent.BlockingQueue<IMessagePublication> messageQueue
-
dispatcherThreadFactory
private java.util.concurrent.ThreadFactory dispatcherThreadFactory
-
-
Method Detail
-
Default
public static final Feature.AsynchronousMessageDispatch Default()
-
getNumberOfMessageDispatchers
public int getNumberOfMessageDispatchers()
-
setNumberOfMessageDispatchers
public Feature.AsynchronousMessageDispatch setNumberOfMessageDispatchers(int numberOfMessageDispatchers)
-
getMessageQueue
public java.util.concurrent.BlockingQueue<IMessagePublication> getMessageQueue()
-
setMessageQueue
public Feature.AsynchronousMessageDispatch setMessageQueue(java.util.concurrent.BlockingQueue<IMessagePublication> pendingMessages)
-
getDispatcherThreadFactory
public java.util.concurrent.ThreadFactory getDispatcherThreadFactory()
-
setDispatcherThreadFactory
public Feature.AsynchronousMessageDispatch setDispatcherThreadFactory(java.util.concurrent.ThreadFactory dispatcherThreadFactory)
-
-