クラス DirectChannel

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.channel.AbstractSubscribableChannel
org.springframework.integration.channel.DirectChannel
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、ComponentSourceAware、ExpressionCapable、IntegrationPattern、NamedComponent、IntegrationManagement、SubscribableChannelManagement、TrackableComponent、MessageChannel、SubscribableChannel、InterceptableChannel
public class DirectChannel extends AbstractSubscribableChannel
送信されたメッセージごとに 1 つのサブスクライバーを呼び出すチャネル。呼び出しは送信者のスレッドで発生します。
作成者:
Dave Syer, Mark Fisher, Iwein Fuld, Oleg Zhurakousky, Gary Russell, Artem Bilan

  • コンストラクターの詳細

    • DirectChannel

      public DirectChannel()
      デフォルトの RoundRobinLoadBalancingStrategy でチャネルを作成します。

    • DirectChannel

      public DirectChannel(@Nullable LoadBalancingStrategy loadBalancingStrategy)
      LoadBalancingStrategy を使用して DirectChannel を作成します。null にすることができます。これは、バランシングが適用されないことを意味します。すべてのメッセージは常に最初のサブスクライバーによって処理されます。
      パラメーター:
      loadBalancingStrategy - 負荷分散戦略の実装。
      関連事項:

  • メソッドの詳細

    • setFailover

      public void setFailover(boolean failover)
      チャネルのディスパッチャーでフェイルオーバーを有効にするかどうかを指定します。デフォルトでは有効になっています。無効にするには、この値を "false" に設定します。setFailoverStrategy(Predicate) オプションを上書きします。つまり、またはこのオプション、そのオプションを設定する必要があります。
      パラメーター:
      failover - フェールオーバーブール値。

    • setFailoverStrategy

      public void setFailoverStrategy(PredicateSE<ExceptionSE> failoverStrategy)
      スローされた例外に対してチャネルのディスパッチャーがフェイルオーバーを有効にするかどうかの戦略を構成します。setFailover(boolean) オプションをオーバーライドします。つまり、このオプションまたはそのオプションを設定する必要があります。
      パラメーター:
      failoverStrategy - フェールオーバーブール値。
      導入:
      6.3

    • setMaxSubscribers

      public void setMaxSubscribers(int maxSubscribers)
      チャネルのディスパッチャーがサポートするサブスクライバの最大数を指定します。
      パラメーター:
      maxSubscribers - 許可されるサブスクライバーの最大数。

    • getDispatcher

      protected UnicastingDispatcher getDispatcher()
      次で指定:
      クラス AbstractSubscribableChannel の getDispatcher 

    • onInit

      protected void onInit()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス AbstractMessageChannel の onInit