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.ThreadFactorydispatcherThreadFactoryprotected static java.util.concurrent.ThreadFactoryMessageDispatchThreadFactoryprivate java.util.concurrent.BlockingQueue<IMessagePublication>messageQueueprivate intnumberOfMessageDispatchers
-
Constructor Summary
Constructors Constructor Description AsynchronousMessageDispatch()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static Feature.AsynchronousMessageDispatchDefault()java.util.concurrent.ThreadFactorygetDispatcherThreadFactory()java.util.concurrent.BlockingQueue<IMessagePublication>getMessageQueue()intgetNumberOfMessageDispatchers()Feature.AsynchronousMessageDispatchsetDispatcherThreadFactory(java.util.concurrent.ThreadFactory dispatcherThreadFactory)Feature.AsynchronousMessageDispatchsetMessageQueue(java.util.concurrent.BlockingQueue<IMessagePublication> pendingMessages)Feature.AsynchronousMessageDispatchsetNumberOfMessageDispatchers(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)
-
-