public abstract class AbstractSubscribableChannel extends AbstractMessageChannel implements SubscribableChannel
SubscribableChannel
implementations.logger
INDEFINITE_TIMEOUT
Constructor and Description |
---|
AbstractSubscribableChannel() |
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
hasSubscription(MessageHandler handler)
Whether the given
MessageHandler is already subscribed. |
boolean |
subscribe(MessageHandler handler)
Register a
MessageHandler as a subscriber to this channel. |
protected abstract boolean |
subscribeInternal(MessageHandler handler)
Subscribe the given
MessageHandler . |
boolean |
unsubscribe(MessageHandler handler)
Remove a
MessageHandler from the subscribers of this channel. |
protected abstract boolean |
unsubscribeInternal(MessageHandler handler)
Unsubscribe the given
MessageHandler . |
addInterceptor, getBeanName, getInterceptorChain, getInterceptors, send, send, sendInternal, setBeanName, setInterceptors, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
send, send
public final boolean subscribe(MessageHandler handler)
SubscribableChannel
MessageHandler
as a subscriber to this channel.subscribe
in interface SubscribableChannel
true
if the channel was not already subscribed to the specified
handlerprotected abstract boolean hasSubscription(MessageHandler handler)
MessageHandler
is already subscribed.protected abstract boolean subscribeInternal(MessageHandler handler)
MessageHandler
.public final boolean unsubscribe(MessageHandler handler)
SubscribableChannel
MessageHandler
from the subscribers of this channel.unsubscribe
in interface SubscribableChannel
true
if the channel was previously subscribed to the specified
handlerprotected abstract boolean unsubscribeInternal(MessageHandler handler)
MessageHandler
.