public class ExecutorSubscribableChannel extends AbstractSubscribableChannel
SubscribableChannel that sends messages to each of its subscribers.loggerINDEFINITE_TIMEOUT| Constructor and Description |
|---|
ExecutorSubscribableChannel()
Create a new
ExecutorSubscribableChannel instance where messages will be sent
in the callers thread. |
ExecutorSubscribableChannel(Executor executor)
Create a new
ExecutorSubscribableChannel instance where messages will be sent
via the specified executor. |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
hasSubscription(MessageHandler handler) |
boolean |
sendInternal(Message<?> message,
long timeout) |
boolean |
subscribeInternal(MessageHandler handler) |
boolean |
unsubscribeInternal(MessageHandler handler) |
getBeanName, send, send, setBeanName, subscribe, unsubscribepublic ExecutorSubscribableChannel()
ExecutorSubscribableChannel instance where messages will be sent
in the callers thread.public ExecutorSubscribableChannel(Executor executor)
ExecutorSubscribableChannel instance where messages will be sent
via the specified executor.executor - the executor used to send the message or null to execute in
the callers thread.protected boolean hasSubscription(MessageHandler handler)
hasSubscription in class AbstractSubscribableChannelpublic boolean sendInternal(Message<?> message, long timeout)
sendInternal in class AbstractSubscribableChannelpublic boolean subscribeInternal(MessageHandler handler)
subscribeInternal in class AbstractSubscribableChannelpublic boolean unsubscribeInternal(MessageHandler handler)
unsubscribeInternal in class AbstractSubscribableChannel