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
A
SubscribableChannel
that 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
ConstructorDescriptionCreate a newExecutorSubscribableChannel
instance where messages will be sent in the callers thread.ExecutorSubscribableChannel
(Executor executor) Create a newExecutorSubscribableChannel
instance where messages will be sent via the specified executor. -
Method Summary
Modifier and TypeMethodDescriptionvoid
addInterceptor
(int index, ChannelInterceptor interceptor) Add a channel interceptor at the specified index.void
addInterceptor
(ChannelInterceptor interceptor) Add a channel interceptor to the end of the list.boolean
sendInternal
(Message<?> message, long timeout) void
setInterceptors
(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
getBeanName, getInterceptors, getLogger, removeInterceptor, removeInterceptor, send, send, setBeanName, setLogger, 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 Details
-
ExecutorSubscribableChannel
public ExecutorSubscribableChannel()Create a newExecutorSubscribableChannel
instance where messages will be sent in the callers thread. -
ExecutorSubscribableChannel
Create a newExecutorSubscribableChannel
instance where messages will be sent via the specified executor.- Parameters:
executor
- the executor used to send the message, ornull
to execute in the callers thread.
-
-
Method Details
-
getExecutor
-
setInterceptors
Description copied from interface:InterceptableChannel
Set the list of channel interceptors clearing any existing interceptors.- Specified by:
setInterceptors
in interfaceInterceptableChannel
- Overrides:
setInterceptors
in classAbstractMessageChannel
-
addInterceptor
Description copied from interface:InterceptableChannel
Add a channel interceptor to the end of the list.- Specified by:
addInterceptor
in interfaceInterceptableChannel
- Overrides:
addInterceptor
in classAbstractMessageChannel
-
addInterceptor
Description copied from interface:InterceptableChannel
Add a channel interceptor at the specified index.- Specified by:
addInterceptor
in interfaceInterceptableChannel
- Overrides:
addInterceptor
in classAbstractMessageChannel
-
sendInternal
- Specified by:
sendInternal
in classAbstractMessageChannel
-