public abstract class AbstractExecutorChannel extends AbstractSubscribableChannel implements ExecutorChannelInterceptorAware
AbstractSubscribableChannel
base implementation for those inheritors
which logic may be based on the Executor
.
Utilizes common operations for the AbstractDispatcher
.
Implements the ExecutorChannelInterceptor
s logic when the message handling
is handed to the Executor.execute(Runnable)
.
ExecutorChannel
,
PublishSubscribeChannel
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractExecutorChannel.MessageHandlingTask |
AbstractMessageChannel.ChannelInterceptorList
IntegrationManagement.ManagementOverrides
Modifier and Type | Field and Description |
---|---|
protected AbstractDispatcher |
dispatcher |
protected java.util.concurrent.Executor |
executor |
protected int |
executorInterceptorsSize |
protected java.lang.Integer |
maxSubscribers |
interceptors
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
Constructor and Description |
---|
AbstractExecutorChannel(java.util.concurrent.Executor executor) |
Modifier and Type | Method and Description |
---|---|
void |
addInterceptor(org.springframework.messaging.support.ChannelInterceptor interceptor)
Add a channel interceptor to the end of the list.
|
void |
addInterceptor(int index,
org.springframework.messaging.support.ChannelInterceptor interceptor)
Add a channel interceptor to the specified index of the list.
|
boolean |
hasExecutorInterceptors() |
boolean |
removeInterceptor(org.springframework.messaging.support.ChannelInterceptor interceptor)
Remove the provided
ChannelInterceptor from the target implementation. |
org.springframework.messaging.support.ChannelInterceptor |
removeInterceptor(int index)
Remove a
ChannelInterceptor from the target implementation for specific index. |
void |
setInterceptors(java.util.List<org.springframework.messaging.support.ChannelInterceptor> interceptors)
Set the list of channel interceptors.
|
void |
setMaxSubscribers(int maxSubscribers)
Specify the maximum number of subscribers supported by the
channel's dispatcher.
|
doSend, getDispatcher, getSubscriberCount, subscribe, unsubscribe
configureMetrics, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMetricsCaptor, getMinSendDuration, getOverrides, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onInit, registerMetricsCaptor, reset, send, send, setCountsEnabled, setDatatypes, setLoggingEnabled, setMessageConverter, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getChannelInterceptors
getComponentName
protected volatile java.util.concurrent.Executor executor
protected volatile AbstractDispatcher dispatcher
protected volatile java.lang.Integer maxSubscribers
protected volatile int executorInterceptorsSize
public AbstractExecutorChannel(java.util.concurrent.Executor executor)
public void setMaxSubscribers(int maxSubscribers)
maxSubscribers
- The maximum number of subscribers allowed.public void setInterceptors(java.util.List<org.springframework.messaging.support.ChannelInterceptor> interceptors)
AbstractMessageChannel
setInterceptors
in interface ChannelInterceptorAware
setInterceptors
in class AbstractMessageChannel
interceptors
- The list of interceptors.public void addInterceptor(org.springframework.messaging.support.ChannelInterceptor interceptor)
AbstractMessageChannel
addInterceptor
in interface ChannelInterceptorAware
addInterceptor
in class AbstractMessageChannel
interceptor
- The interceptor.public void addInterceptor(int index, org.springframework.messaging.support.ChannelInterceptor interceptor)
AbstractMessageChannel
addInterceptor
in interface ChannelInterceptorAware
addInterceptor
in class AbstractMessageChannel
index
- The index to add interceptor.interceptor
- The interceptor.public boolean removeInterceptor(org.springframework.messaging.support.ChannelInterceptor interceptor)
ChannelInterceptorAware
ChannelInterceptor
from the target implementation.removeInterceptor
in interface ChannelInterceptorAware
removeInterceptor
in class AbstractMessageChannel
interceptor
- ChannelInterceptor
to remove.boolean
if ChannelInterceptor
has been removed.public org.springframework.messaging.support.ChannelInterceptor removeInterceptor(int index)
ChannelInterceptorAware
ChannelInterceptor
from the target implementation for specific index.removeInterceptor
in interface ChannelInterceptorAware
removeInterceptor
in class AbstractMessageChannel
index
- the index for the ChannelInterceptor
to remove.boolean
if the ChannelInterceptor
has been removed.public boolean hasExecutorInterceptors()
hasExecutorInterceptors
in interface ExecutorChannelInterceptorAware