クラス BoundRabbitChannelAdvice

java.lang.ObjectSE
org.springframework.integration.amqp.support.BoundRabbitChannelAdvice
実装済みのインターフェース一覧:
Advice, Interceptor, MethodInterceptor, HandleMessageAdvice
public class BoundRabbitChannelAdvice extends ObjectSE implements HandleMessageAdvice
スレッドハンドオフが発生しない限り、すべての下流 RabbitOperations 操作を同じチャネルで実行させる HandleMessageAdvice。これは、チャネルがスレッドにバインドされているためです。この HandleMessageAdvice とすべての下流コンポーネントで同じ RabbitOperations を使用する必要があります。通常、スプリッターなどの複数のメッセージを送信するメカニズムと組み合わせて使用されます。チャネルがパブリッシャーの確認を待機するように構成されている場合は、オプションでパブリッシャーの確認を待機します。
導入:
5.1
作成者:
Gary Russell, Artem Bilan

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

    • BoundRabbitChannelAdvice

      public BoundRabbitChannelAdvice(RabbitOperations operations)
      確認を待たないインスタンスを作成します。
      パラメーター:
      operations - 操作。

    • BoundRabbitChannelAdvice

      public BoundRabbitChannelAdvice(RabbitOperations operations, @Nullable DurationSE waitForConfirmsTimeout)
      パブリッシャーの確認を待機するインスタンスを構築します (構成されていて、waitForConfirmsTimeout が null でない場合)。
      パラメーター:
      operations - 操作。
      waitForConfirmsTimeout - タイムアウト。

  • 方法の詳細