ExecutorSubscribableChannel

A {@link SubscribableChannel} that sends messages to each of its subscribers.

@author Phillip Webb @author Rossen Stoyanchev @since 4.0

class ExecutorSubscribableChannel : AbstractSubscribableChannel {

}

Constructors

this this(): Create a new {@link ExecutorSubscribableChannel} instance where messages will be sent in the callers thread.
this this(Executor executor): Create a new {@link ExecutorSubscribableChannel} instance where messages will be sent via the specified executor. @param executor the executor used to send the message, or {@code null} to execute in the callers thread.

addInterceptor void addInterceptor(ChannelInterceptor interceptor): Undocumented in source. Be warned that the author may not have intended to support it.
addInterceptor void addInterceptor(int index, ChannelInterceptor interceptor): Undocumented in source. Be warned that the author may not have intended to support it.
getExecutor Executor getExecutor(): Undocumented in source. Be warned that the author may not have intended to support it.
sendInternal bool sendInternal(MessageBase message, long timeout): Undocumented in source. Be warned that the author may not have intended to support it.
setInterceptors void setInterceptors(ChannelInterceptor[] interceptors): Undocumented in source. Be warned that the author may not have intended to support it.

getSubscribers Set!(MessageHandler) getSubscribers(): Undocumented in source. Be warned that the author may not have intended to support it.
hasSubscription bool hasSubscription(MessageHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.
subscribe bool subscribe(MessageHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.
unsubscribe bool unsubscribe(MessageHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.