クラス BoundRabbitChannelAdvice

java.lang.ObjectSE
org.springframework.integration.amqp.support.BoundRabbitChannelAdvice
実装されたすべてのインターフェース:
Advice、Interceptor、MethodInterceptor、HandleMessageAdvice
public class BoundRabbitChannelAdvice extends ObjectSE implements HandleMessageAdvice
チャネルはスレッドにバインドされているため、スレッドのハンドオフがない限り、すべてのダウンストリーム RabbitOperations 操作が同じチャネルで実行されるようにするアドバイス。このコンポーネントとすべてのダウンストリームコンポーネントで同じ 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 - タイムアウト。

  • メソッドの詳細