Class ExecutorSubscribableChannel
- java.lang.Object
- org.springframework.messaging.support.AbstractMessageChannel
- org.springframework.messaging.support.AbstractSubscribableChannel
- org.springframework.messaging.support.ExecutorSubscribableChannel
- All Implemented Interfaces:
Aware,BeanNameAware,MessageChannel,SubscribableChannel,InterceptableChannel
public class ExecutorSubscribableChannel extends AbstractSubscribableChannel
ASubscribableChannelthat sends messages to each of its subscribers.- Since:
- 4.0
- Author:
- Phillip Webb, Rossen Stoyanchev
Nested Class Summary
Nested classes/interfaces inherited from class org.springframework.messaging.support.AbstractMessageChannel
AbstractMessageChannel.ChannelInterceptorChain
Field Summary
Fields inherited from class org.springframework.messaging.support.AbstractMessageChannel
logger
Fields inherited from interface org.springframework.messaging.MessageChannel
INDEFINITE_TIMEOUT
Constructor Summary
Constructors Constructor Description ExecutorSubscribableChannel()Create a newExecutorSubscribableChannelinstance where messages will be sent in the callers thread.ExecutorSubscribableChannel(Executor executor)Create a newExecutorSubscribableChannelinstance where messages will be sent via the specified executor.
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddInterceptor(ChannelInterceptor interceptor)Add a channel interceptor to the end of the list.ExecutorgetExecutor()booleansendInternal(Message<?> message, long timeout)voidsetInterceptors(List<ChannelInterceptor> interceptors)Set the list of channel interceptors clearing any existing interceptors.Methods inherited from class org.springframework.messaging.support.AbstractSubscribableChannel
getSubscribers, hasSubscription, subscribe, unsubscribe
Methods inherited from class org.springframework.messaging.support.AbstractMessageChannel
addInterceptor, getBeanName, getInterceptors, removeInterceptor, removeInterceptor, send, send, setBeanName, toString
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.springframework.messaging.MessageChannel
send, send
Constructor Detail
ExecutorSubscribableChannel
public ExecutorSubscribableChannel()
Create a newExecutorSubscribableChannelinstance where messages will be sent in the callers thread.
ExecutorSubscribableChannel
public ExecutorSubscribableChannel(Executor executor)
Create a newExecutorSubscribableChannelinstance where messages will be sent via the specified executor.- Parameters:
executor- the executor used to send the message, ornullto execute in the callers thread.
Method Detail
getExecutor
public Executor getExecutor()
setInterceptors
public void setInterceptors(List<ChannelInterceptor> interceptors)
Description copied from interface:InterceptableChannelSet the list of channel interceptors clearing any existing interceptors.- Specified by:
setInterceptorsin interfaceInterceptableChannel- Overrides:
setInterceptorsin classAbstractMessageChannel
addInterceptor
public void addInterceptor(ChannelInterceptor interceptor)
Description copied from interface:InterceptableChannelAdd a channel interceptor to the end of the list.- Specified by:
addInterceptorin interfaceInterceptableChannel- Overrides:
addInterceptorin classAbstractMessageChannel
sendInternal
public boolean sendInternal(Message<?> message, long timeout)
- Specified by:
sendInternalin classAbstractMessageChannel