public class DirectChannel extends AbstractSubscribableChannel
AbstractMessageChannel.ChannelInterceptorListIntegrationManagement.ManagementOverridesinterceptors, metersEXPRESSION_PARSER, loggerINDEFINITE_TIMEOUTMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| コンストラクターと説明 |
|---|
DirectChannel() デフォルトの RoundRobinLoadBalancingStrategy でチャネルを作成します |
DirectChannel(LoadBalancingStrategy loadBalancingStrategy)LoadBalancingStrategy を使用して DirectChannel を作成します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected UnicastingDispatcher | getDispatcher() |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
void | setFailover(boolean failover) チャネルのディスパッチャーでフェイルオーバーを有効にするかどうかを指定します。 |
void | setMaxSubscribers(int maxSubscribers) チャネルのディスパッチャーがサポートするサブスクライバの最大数を指定します。 |
doSend, getSubscriberCount, subscribe, unsubscribeaddInterceptor, addInterceptor, destroy, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isLoggingEnabled, registerMetricsCaptor, removeInterceptor, removeInterceptor, send, send, setDatatypes, setInterceptors, 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, waitSEsend, sendgetManagedName, getManagedType, getThisAs, setManagedName, setManagedTypegetBeanName, getComponentNamepublic DirectChannel()
RoundRobinLoadBalancingStrategy でチャネルを作成します public DirectChannel(@Nullable LoadBalancingStrategy loadBalancingStrategy)
LoadBalancingStrategy を使用して DirectChannel を作成します。null にすることができます。これは、バランシングが適用されないことを意味します。すべてのメッセージは常に最初のサブスクライバーによって処理されます。loadBalancingStrategy - 負荷分散戦略の実装。setFailover(boolean)public void setFailover(boolean failover)
failover - フェールオーバーブール値。public void setMaxSubscribers(int maxSubscribers)
maxSubscribers - 許可されるサブスクライバーの最大数。protected UnicastingDispatcher getDispatcher()
AbstractSubscribableChannel の getDispatcher protected void onInit()
IntegrationObjectSupportAbstractMessageChannel の onInit