public class ExecutorChannel extends AbstractExecutorChannel
UnicastingDispatcher のインスタンスに委譲する MessageChannel の実装。次に、すべてのディスパッチ呼び出しを ExecutorSE に委譲します。 注 :DirectChannel とは異なり、ExecutorChannel は、ディスパッチに別のスレッドを使用するため、ExecutorSE は通常、送信者のスレッドをブロックしないため、送信者とハンドラー間の共有トランザクションコンテキストをサポートしません。(SyncTaskExecutor は例外ですが、このチャネルには値を提供しません。同期ディスパッチが必要な場合は、代わりに DirectChannel を使用する必要があります)。
AbstractExecutorChannel.MessageHandlingTaskAbstractMessageChannel.ChannelInterceptorListIntegrationManagement.ManagementOverridesdispatcher, executor, executorInterceptorsSize, maxSubscribersinterceptors, metersEXPRESSION_PARSER, loggerINDEFINITE_TIMEOUTMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| コンストラクターと説明 |
|---|
ExecutorChannel(ExecutorSE executor) メッセージをディスパッチするときに、提供された ExecutorSE に委譲する ExecutorChannel を作成します。 |
ExecutorChannel(ExecutorSE executor, LoadBalancingStrategy loadBalancingStrategy) メッセージをディスパッチするときに提供された ExecutorSE に委譲する LoadBalancingStrategy を使用して ExecutorChannel を作成します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected UnicastingDispatcher | getDispatcher() |
void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
void | setFailover(boolean failover) チャネルのディスパッチャーでフェイルオーバーを有効にするかどうかを指定します。 |
addInterceptor, addInterceptor, getIntegrationPatternType, hasExecutorInterceptors, removeInterceptor, removeInterceptor, setInterceptors, setMaxSubscribersdoSend, getSubscriberCount, subscribe, unsubscribedestroy, getComponentType, getFullChannelName, getIChannelInterceptorList, getInterceptors, getMetricsCaptor, getOverrides, isLoggingEnabled, registerMetricsCaptor, send, send, setDatatypes, setLoggingEnabled, setMessageConverter, setShouldTrackafterPropertiesSet, 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, toStringcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEgetInterceptorssend, sendgetManagedName, getManagedType, getThisAs, setManagedName, setManagedTypegetBeanName, getComponentNamepublic ExecutorChannel(ExecutorSE executor)
ExecutorSE に委譲する ExecutorChannel を作成します。エグゼキューターを null にすることはできません。
executor - エグゼキューター。public ExecutorChannel(ExecutorSE executor, LoadBalancingStrategy loadBalancingStrategy)
ExecutorSE に委譲する LoadBalancingStrategy を使用して ExecutorChannel を作成します。エグゼキューターを null にすることはできません。
executor - エグゼキューター。loadBalancingStrategy - 負荷分散戦略の実装。public void setFailover(boolean failover)
failover - フェールオーバーブール値。protected UnicastingDispatcher getDispatcher()
AbstractSubscribableChannel の getDispatcher public final void onInit()
IntegrationObjectSupportAbstractMessageChannel の onInit