Class AbstractDispatcher
java.lang.Object
org.springframework.integration.dispatcher.AbstractDispatcher
- All Implemented Interfaces:
MessageDispatcher
- Direct Known Subclasses:
BroadcastingDispatcher,UnicastingDispatcher
Base class for
MessageDispatcher implementations.
The subclasses implement the actual dispatching strategy, but this base class
manages the registration of MessageHandlers. Although the implemented
dispatching strategies may invoke handles in different ways (e.g. round-robin
vs. failover), this class does maintain the order of the underlying
collection. See the OrderedAwareCopyOnWriteArraySet for more detail.
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanaddHandler(org.springframework.messaging.MessageHandler handler) Add the handler to the internal Set.intReturn the current handler count.protected Set<org.springframework.messaging.MessageHandler>Returns an unmodifiableSetof this dispatcher's handlers.booleanremoveHandler(org.springframework.messaging.MessageHandler handler) Remove the handler from the internal handler Set.voidsetMaxSubscribers(int maxSubscribers) Set the maximum subscribers allowed by this dispatcher.toString()protected booleantryOptimizedDispatch(org.springframework.messaging.Message<?> message) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.springframework.integration.dispatcher.MessageDispatcher
dispatch
-
Field Details
-
logger
protected final org.apache.commons.logging.Log logger
-
-
Constructor Details
-
AbstractDispatcher
public AbstractDispatcher()
-
-
Method Details
-
setMaxSubscribers
public void setMaxSubscribers(int maxSubscribers) Set the maximum subscribers allowed by this dispatcher.- Parameters:
maxSubscribers- The maximum number of subscribers allowed.
-
getHandlers
Returns an unmodifiableSetof this dispatcher's handlers. This is provided for access by subclasses.- Returns:
- The message handlers.
-
addHandler
public boolean addHandler(org.springframework.messaging.MessageHandler handler) Add the handler to the internal Set.- Specified by:
addHandlerin interfaceMessageDispatcher- Parameters:
handler- The handler to add.- Returns:
- the result of
Set.add(Object)
-
removeHandler
public boolean removeHandler(org.springframework.messaging.MessageHandler handler) Remove the handler from the internal handler Set.- Specified by:
removeHandlerin interfaceMessageDispatcher- Parameters:
handler- the handler.- Returns:
- the result of
Set.remove(Object)
-
tryOptimizedDispatch
protected boolean tryOptimizedDispatch(org.springframework.messaging.Message<?> message) -
toString
-
getHandlerCount
public int getHandlerCount()Description copied from interface:MessageDispatcherReturn the current handler count.- Specified by:
getHandlerCountin interfaceMessageDispatcher- Returns:
- the handler count.
-