public abstract class AbstractSubscribableChannel extends AbstractMessageChannel implements SubscribableChannel
MessageChannel
that invokes the subscribed
handler(s)
by delegating to a MessageDispatcher
.AbstractMessageChannel.ChannelInterceptorList
logger
INDEFINITE_TIMEOUT
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) |
boolean |
unsubscribe(MessageHandler handle) |
addInterceptor, addInterceptor, getChannelInterceptors, getComponentType, getFullChannelName, getInterceptors, onInit, send, send, setConversionService, setDatatypes, setInterceptors, setMessageConverter, setShouldTrack
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setMessageBuilderFactory, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
send, send
getComponentName
public boolean subscribe(MessageHandler handler)
subscribe
in interface SubscribableChannel
public boolean unsubscribe(MessageHandler handle)
unsubscribe
in interface SubscribableChannel
protected boolean doSend(Message<?> message, long timeout)
AbstractMessageChannel
doSend
in class AbstractMessageChannel
message
- The message.timeout
- The timeout.protected abstract MessageDispatcher getDispatcher()