public abstract class AbstractSubscribableChannel extends AbstractMessageChannel implements SubscribableChannel
SubscribableChannel implementations.loggerINDEFINITE_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, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitsend, sendpublic final boolean subscribe(MessageHandler handler)
SubscribableChannelMessageHandler as a subscriber to this channel.subscribe in interface SubscribableChanneltrue 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)
SubscribableChannelMessageHandler from the subscribers of this channel.unsubscribe in interface SubscribableChanneltrue if the channel was previously subscribed to the specified
handlerprotected abstract boolean unsubscribeInternal(MessageHandler handler)
MessageHandler.