public class PollableJmsChannel extends AbstractJmsChannel implements PollableChannel, PollableChannelManagement, ExecutorChannelInterceptorAware
AbstractMessageChannel.ChannelInterceptorList
interceptors
EXPRESSION_PARSER, logger
INDEFINITE_TIMEOUT
Constructor and Description |
---|
PollableJmsChannel(JmsTemplate jmsTemplate) |
Modifier and Type | Method and Description |
---|---|
void |
addInterceptor(ChannelInterceptor interceptor)
Add a channel interceptor to the end of the list.
|
void |
addInterceptor(int index,
ChannelInterceptor interceptor)
Add a channel interceptor to the specified index of the list.
|
int |
getReceiveCount() |
long |
getReceiveCountLong() |
int |
getReceiveErrorCount() |
long |
getReceiveErrorCountLong() |
boolean |
hasExecutorInterceptors() |
Message<?> |
receive() |
Message<?> |
receive(long timeout) |
boolean |
removeInterceptor(ChannelInterceptor interceptor)
Remove the provided
ChannelInterceptor from the target implementation. |
ChannelInterceptor |
removeInterceptor(int index)
Remove a
ChannelInterceptor from the target implementation for specific index. |
void |
setInterceptors(List<ChannelInterceptor> interceptors)
Set the list of channel interceptors.
|
void |
setMessageSelector(String messageSelector) |
doSend
configureMetrics, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMinSendDuration, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onInit, 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
send, send
getErrorRate, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMinSendDuration, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend
isStatsEnabled, setStatsEnabled
isCountsEnabled, isLoggingEnabled, reset, setCountsEnabled, setLoggingEnabled
getChannelInterceptors
getComponentName
public PollableJmsChannel(JmsTemplate jmsTemplate)
public void setMessageSelector(String messageSelector)
public int getReceiveCount()
getReceiveCount
in interface PollableChannelManagement
public long getReceiveCountLong()
getReceiveCountLong
in interface PollableChannelManagement
public int getReceiveErrorCount()
getReceiveErrorCount
in interface PollableChannelManagement
public long getReceiveErrorCountLong()
getReceiveErrorCountLong
in interface PollableChannelManagement
public Message<?> receive()
receive
in interface PollableChannel
public Message<?> receive(long timeout)
receive
in interface PollableChannel
public void setInterceptors(List<ChannelInterceptor> interceptors)
AbstractMessageChannel
setInterceptors
in interface ChannelInterceptorAware
setInterceptors
in class AbstractMessageChannel
interceptors
- The list of interceptors.public void addInterceptor(ChannelInterceptor interceptor)
AbstractMessageChannel
addInterceptor
in interface ChannelInterceptorAware
addInterceptor
in class AbstractMessageChannel
interceptor
- The interceptor.public void addInterceptor(int index, ChannelInterceptor interceptor)
AbstractMessageChannel
addInterceptor
in interface ChannelInterceptorAware
addInterceptor
in class AbstractMessageChannel
index
- The index to add interceptor.interceptor
- The interceptor.public boolean removeInterceptor(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 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