public class PollableJmsChannel extends AbstractJmsChannel implements PollableChannel, ExecutorChannelInterceptorAware
AbstractMessageChannel.ChannelInterceptorList
IntegrationManagement.ManagementOverrides
interceptors, meters
EXPRESSION_PARSER, logger
INDEFINITE_TIMEOUT
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
PollableJmsChannel(JmsTemplate jmsTemplate) |
修飾子と型 | メソッドと説明 |
---|---|
void | addInterceptor(ChannelInterceptor interceptor) リストの最後にチャネルインターセプターを追加します。 |
void | addInterceptor(int index, ChannelInterceptor interceptor) リストの指定されたインデックスにチャネルインターセプターを追加します。 |
boolean | hasExecutorInterceptors() |
Message<?> | receive() |
Message<?> | receive(long timeout) |
boolean | removeInterceptor(ChannelInterceptor interceptor) |
ChannelInterceptor | removeInterceptor(int index) |
void | setInterceptors(ListSE<ChannelInterceptor> interceptors) チャネルインターセプターのリストを設定します。 |
void | setMessageSelector(StringSE messageSelector) |
doSend
destroy, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isLoggingEnabled, onInit, registerMetricsCaptor, send, send, setDatatypes, setLoggingEnabled, setMessageConverter, setShouldTrack
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
send, send
getInterceptors
getManagedName, getManagedType, getThisAs, setManagedName, setManagedType
getBeanName, getComponentName
public PollableJmsChannel(JmsTemplate jmsTemplate)
public void setMessageSelector(StringSE messageSelector)
@Nullable public Message<?> receive(long timeout)
PollableChannel
の receive
@Nullable public Message<?> receive()
PollableChannel
の receive
public void setInterceptors(ListSE<ChannelInterceptor> interceptors)
AbstractMessageChannel
InterceptableChannel
の setInterceptors
AbstractMessageChannel
の setInterceptors
interceptors
- インターセプターのリスト。public void addInterceptor(ChannelInterceptor interceptor)
AbstractMessageChannel
InterceptableChannel
の addInterceptor
AbstractMessageChannel
の addInterceptor
interceptor
- インターセプター。public void addInterceptor(int index, ChannelInterceptor interceptor)
AbstractMessageChannel
InterceptableChannel
の addInterceptor
AbstractMessageChannel
の addInterceptor
index
- インターセプターを追加するためのインデックス。interceptor
- インターセプター。public boolean removeInterceptor(ChannelInterceptor interceptor)
InterceptableChannel
の removeInterceptor
AbstractMessageChannel
の removeInterceptor
@Nullable public ChannelInterceptor removeInterceptor(int index)
InterceptableChannel
の removeInterceptor
AbstractMessageChannel
の removeInterceptor
public boolean hasExecutorInterceptors()
ExecutorChannelInterceptorAware
の hasExecutorInterceptors