public class ExecutorSubscribableChannel extends AbstractSubscribableChannel
SubscribableChannel
。AbstractMessageChannel.ChannelInterceptorChain
logger
INDEFINITE_TIMEOUT
コンストラクターと説明 |
---|
ExecutorSubscribableChannel() メッセージが呼び出し元スレッドで送信される新しい ExecutorSubscribableChannel インスタンスを作成します。 |
ExecutorSubscribableChannel(ExecutorSE executor) 指定されたエグゼキューターを介してメッセージが送信される新しい ExecutorSubscribableChannel インスタンスを作成します。 |
修飾子と型 | メソッドと説明 |
---|---|
void | addInterceptor(ChannelInterceptor interceptor) リストの最後にチャネルインターセプターを追加します。 |
void | addInterceptor(int index, ChannelInterceptor interceptor) 指定したインデックスにチャネルインターセプターを追加します。 |
ExecutorSE | getExecutor() |
boolean | sendInternal(Message<?> message, long timeout) |
void | setInterceptors(ListSE<ChannelInterceptor> interceptors) 既存のインターセプターをクリアするチャネルインターセプターのリストを設定します。 |
getSubscribers, hasSubscription, subscribe, unsubscribe
getBeanName, getInterceptors, getLogger, removeInterceptor, removeInterceptor, send, send, setBeanName, setLogger, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
send, send
public ExecutorSubscribableChannel()
ExecutorSubscribableChannel
インスタンスを作成します。public ExecutorSubscribableChannel(@Nullable ExecutorSE executor)
ExecutorSubscribableChannel
インスタンスを作成します。executor
- メッセージを送信するために使用されるエグゼキュータ、または呼び出し側スレッドで実行するための null
@Nullable public ExecutorSE getExecutor()
public void setInterceptors(ListSE<ChannelInterceptor> interceptors)
InterceptableChannel
InterceptableChannel
の setInterceptors
AbstractMessageChannel
の setInterceptors
public void addInterceptor(ChannelInterceptor interceptor)
InterceptableChannel
InterceptableChannel
の addInterceptor
AbstractMessageChannel
の addInterceptor
public void addInterceptor(int index, ChannelInterceptor interceptor)
InterceptableChannel
InterceptableChannel
の addInterceptor
AbstractMessageChannel
の addInterceptor
public boolean sendInternal(Message<?> message, long timeout)
AbstractMessageChannel
の sendInternal