public abstract class AbstractSubscribableChannel extends AbstractMessageChannel implements SubscribableChannel
MessageChannel that invokes the subscribed
handler(s) by delegating to a MessageDispatcher.AbstractMessageChannel.ChannelInterceptorListlogger| Constructor and Description |
|---|
AbstractSubscribableChannel() |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
doSend(Message<?> message,
long timeout)
Subclasses must implement this method.
|
protected abstract MessageDispatcher |
getDispatcher() |
boolean |
subscribe(MessageHandler handler)
Register a
MessageHandler as a subscriber to this channel. |
boolean |
unsubscribe(MessageHandler handle)
Remove a
MessageHandler from the subscribers of this channel. |
addInterceptor, getComponentType, getFullChannelName, getInterceptors, send, send, setConversionService, setDatatypes, setInterceptors, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, onInit, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitsend, sendgetComponentNamepublic boolean subscribe(MessageHandler handler)
SubscribableChannelMessageHandler as a subscriber to this channel.subscribe in interface SubscribableChannelpublic boolean unsubscribe(MessageHandler handle)
SubscribableChannelMessageHandler from the subscribers of this channel.unsubscribe in interface SubscribableChannelprotected boolean doSend(Message<?> message, long timeout)
AbstractMessageChanneldoSend in class AbstractMessageChannelprotected abstract MessageDispatcher getDispatcher()