public class ExecutorSubscribableChannel extends AbstractSubscribableChannel
SubscribableChannel。AbstractMessageChannel.ChannelInterceptorChainloggerINDEFINITE_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, unsubscribegetBeanName, getInterceptors, getLogger, removeInterceptor, removeInterceptor, send, send, setBeanName, setLogger, toStringcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEsend, sendpublic ExecutorSubscribableChannel()
ExecutorSubscribableChannel インスタンスを作成します。public ExecutorSubscribableChannel(@Nullable ExecutorSE executor)
ExecutorSubscribableChannel インスタンスを作成します。executor - メッセージを送信するために使用されるエグゼキュータ、または呼び出し側スレッドで実行するための null @Nullable public ExecutorSE getExecutor()
public void setInterceptors(ListSE<ChannelInterceptor> interceptors)
InterceptableChannelInterceptableChannel の setInterceptors AbstractMessageChannel の setInterceptors public void addInterceptor(ChannelInterceptor interceptor)
InterceptableChannelInterceptableChannel の addInterceptor AbstractMessageChannel の addInterceptor public void addInterceptor(int index,
ChannelInterceptor interceptor)InterceptableChannelInterceptableChannel の addInterceptor AbstractMessageChannel の addInterceptor public boolean sendInternal(Message<?> message, long timeout)
AbstractMessageChannel の sendInternal