public class ExecutorSubscribableChannel extends AbstractSubscribableChannel
SubscribableChannel
AbstractMessageChannel.ChannelInterceptorChain
logger
INDEFINITE_TIMEOUT
ExecutorSubscribableChannel()
ExecutorSubscribableChannel
ExecutorSubscribableChannel(java.util.concurrent.Executor executor)
void
addInterceptor(ChannelInterceptor interceptor)
addInterceptor(int index, ChannelInterceptor interceptor)
java.util.concurrent.Executor
getExecutor()
boolean
sendInternal(Message<?> message, long timeout)
setInterceptors(java.util.List<ChannelInterceptor> interceptors)
getSubscribers, hasSubscription, subscribe, unsubscribe
getBeanName, getInterceptors, getLogger, removeInterceptor, removeInterceptor, send, send, setBeanName, setLogger, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
send, send
public ExecutorSubscribableChannel()
public ExecutorSubscribableChannel(@Nullable java.util.concurrent.Executor executor)
executor
null
@Nullable public java.util.concurrent.Executor getExecutor()
public void setInterceptors(java.util.List<ChannelInterceptor> interceptors)
InterceptableChannel
setInterceptors
AbstractMessageChannel
public void addInterceptor(ChannelInterceptor interceptor)
addInterceptor
public void addInterceptor(int index, ChannelInterceptor interceptor)
public boolean sendInternal(Message<?> message, long timeout)
sendInternal
Impressum und Datenschutz Copyright ©2018 eir.me