public abstract class AbstractPollableChannel extends AbstractMessageChannel implements PollableChannel, ExecutorChannelInterceptorAware
AbstractMessageChannel.ChannelInterceptorList
IntegrationManagement.ManagementOverrides
interceptors, meters
EXPRESSION_PARSER, logger
INDEFINITE_TIMEOUT
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
AbstractPollableChannel() |
修飾子と型 | メソッドと説明 |
---|---|
void | addInterceptor(ChannelInterceptor interceptor) リストの最後にチャネルインターセプターを追加します。 |
void | addInterceptor(int index, ChannelInterceptor interceptor) リストの指定されたインデックスにチャネルインターセプターを追加します。 |
protected abstract Message<?> | doReceive(long timeout) サブクラスはこのメソッドを実装する必要があります。 |
IntegrationPatternType | getIntegrationPatternType() このコンポーネントが実装するパターン型を返します。 |
boolean | hasExecutorInterceptors() |
Message<?> | receive() このチャネルから最初に利用可能なメッセージを受信します。 |
Message<?> | receive(long timeout) このチャネルから最初に利用可能なメッセージを受信します。 |
boolean | removeInterceptor(ChannelInterceptor interceptor) |
ChannelInterceptor | removeInterceptor(int index) |
void | setInterceptors(ListSE<ChannelInterceptor> interceptors) チャネルインターセプターのリストを設定します。 |
destroy, doSend, getComponentType, getFullChannelName, getIChannelInterceptorList, 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 IntegrationPatternType getIntegrationPatternType()
IntegrationPattern
IntegrationPattern
の getIntegrationPatternType
AbstractMessageChannel
の getIntegrationPatternType
IntegrationPatternType
@Nullable public Message<?> receive()
PollableChannel
の receive
null
。@Nullable public Message<?> receive(long timeout)
receive()
を参照)。PollableChannel
の receive
timeout
- ミリ秒単位のタイムアウト null
。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