public abstract class AbstractDispatcher extends java.lang.Object implements MessageDispatcher
MessageDispatcher
implementations.
The subclasses implement the actual dispatching strategy, but this base class
manages the registration of MessageHandler
s. 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.
Modifier and Type | Field and Description |
---|---|
protected org.apache.commons.logging.Log |
logger |
Constructor and Description |
---|
AbstractDispatcher() |
Modifier and Type | Method and Description |
---|---|
boolean |
addHandler(org.springframework.messaging.MessageHandler handler)
Add the handler to the internal Set.
|
int |
getHandlerCount()
Return the current handler count.
|
protected java.util.Set<org.springframework.messaging.MessageHandler> |
getHandlers()
Returns an unmodifiable
Set of this dispatcher's handlers. |
boolean |
removeHandler(org.springframework.messaging.MessageHandler handler)
Remove the handler from the internal handler Set.
|
void |
setMaxSubscribers(int maxSubscribers)
Set the maximum subscribers allowed by this dispatcher.
|
java.lang.String |
toString() |
protected boolean |
tryOptimizedDispatch(org.springframework.messaging.Message<?> message) |
protected java.lang.RuntimeException |
wrapExceptionIfNecessary(org.springframework.messaging.Message<?> message,
java.lang.Exception e) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
dispatch
public void setMaxSubscribers(int maxSubscribers)
maxSubscribers
- The maximum number of subscribers allowed.protected java.util.Set<org.springframework.messaging.MessageHandler> getHandlers()
Set
of this dispatcher's handlers. This
is provided for access by subclasses.public boolean addHandler(org.springframework.messaging.MessageHandler handler)
addHandler
in interface MessageDispatcher
handler
- The handler to add.Set.add(Object)
public boolean removeHandler(org.springframework.messaging.MessageHandler handler)
removeHandler
in interface MessageDispatcher
handler
- the handler.Set.remove(Object)
protected boolean tryOptimizedDispatch(org.springframework.messaging.Message<?> message)
protected java.lang.RuntimeException wrapExceptionIfNecessary(org.springframework.messaging.Message<?> message, java.lang.Exception e)
public java.lang.String toString()
toString
in class java.lang.Object
public int getHandlerCount()
MessageDispatcher
getHandlerCount
in interface MessageDispatcher