public class ExecutorSubscribableChannel extends AbstractSubscribableChannel
SubscribableChannel
that sends messages to each of its subscribers.Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.Executor |
executor |
private java.util.Set<MessageHandler> |
handlers |
logger
INDEFINITE_TIMEOUT
Constructor and Description |
---|
ExecutorSubscribableChannel()
Create a new
ExecutorSubscribableChannel instance where messages will be sent
in the callers thread. |
ExecutorSubscribableChannel(java.util.concurrent.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, unsubscribe
private final java.util.concurrent.Executor executor
private final java.util.Set<MessageHandler> handlers
public ExecutorSubscribableChannel()
ExecutorSubscribableChannel
instance where messages will be sent
in the callers thread.public ExecutorSubscribableChannel(java.util.concurrent.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 AbstractSubscribableChannel
public boolean sendInternal(Message<?> message, long timeout)
sendInternal
in class AbstractSubscribableChannel
public boolean subscribeInternal(MessageHandler handler)
subscribeInternal
in class AbstractSubscribableChannel
public boolean unsubscribeInternal(MessageHandler handler)
unsubscribeInternal
in class AbstractSubscribableChannel