クラス AmqpClientInboundGatewaySpec

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<AmqpClientInboundGatewaySpec, AmqpClientInboundGateway>
org.springframework.integration.dsl.MessagingGatewaySpec<AmqpClientInboundGatewaySpec, AmqpClientInboundGateway>
org.springframework.integration.amqp.dsl.AmqpClientInboundGatewaySpec
実装済みのインターフェース一覧:
DisposableBean, FactoryBean<AmqpClientInboundGateway>, InitializingBean, Lifecycle, Phased, SmartLifecycle
public class AmqpClientInboundGatewaySpec extends MessagingGatewaySpec<AmqpClientInboundGatewaySpec, AmqpClientInboundGateway>
AmqpClientInboundGateway の仕様。
導入:
7.0
作成者:
Artem Bilan

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

  • 方法の詳細

    • initialCredits

      public AmqpClientInboundGatewaySpec initialCredits(int initialCredits)
      AMQP レシーバーに付与する初期クレジット数。デフォルトは 100 です。
      パラメーター:
      initialCredits - 初期単位数
      戻り値:
      スペック

    • priority

      public AmqpClientInboundGatewaySpec priority(int priority)
      コンシューマーの優先。
      パラメーター:
      priority - コンシューマー優先
      戻り値:
      スペック

    • stateListeners

      public AmqpClientInboundGatewaySpec stateListeners(com.rabbitmq.client.amqp.Resource.StateListener... stateListeners)
      Resource.StateListener インスタンスをコンシューマーに追加します。
      パラメーター:
      stateListeners - 追加するリスナー
      戻り値:
      スペック

    • afterReceivePostProcessors

      public AmqpClientInboundGatewaySpec afterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)
      受信したばかりのメッセージに適用する MessagePostProcessor インスタンスを追加します。
      パラメーター:
      afterReceivePostProcessors - 追加するリスナー
      戻り値:
      スペック

    • adviceChain

      public AmqpClientInboundGatewaySpec adviceChain(Advice... advices)
      Advice インスタンスをプロキシメッセージリスナーに設定します。
      パラメーター:
      advices - 追加するアドバイス
      戻り値:
      スペック

    • autoSettle

      public AmqpClientInboundGatewaySpec autoSettle(boolean autoSettle)
      下流フローの手動決済のために確認応答コールバックをメッセージヘッダーに伝播するには、false に設定します。
      パラメーター:
      autoSettle - true はメッセージを自動的に確認します。
      戻り値:
      スペック

    • defaultRequeue

      public AmqpClientInboundGatewaySpec defaultRequeue(boolean defaultRequeue)
      メッセージ処理が失敗した場合のデフォルトの動作を設定します。true の場合、メッセージは再キューされ、false の場合、メッセージは破棄されます。このオプションは、下流フローから AmqpRejectAndDontRequeueException または ImmediateRequeueAmqpException をスローすることでオーバーライドできます。デフォルトは true です。
      パラメーター:
      defaultRequeue - デフォルトで再キューする場合は true です。
      戻り値:
      スペック

    • gracefulShutdownPeriod

      public AmqpClientInboundGatewaySpec gracefulShutdownPeriod(DurationSE gracefulShutdownPeriod)
      リスナーコンテナーの停止時に、すべてのコンシューマーが正常にシャットダウンするまでの待機時間を設定します。デフォルトは 30 秒です。
      パラメーター:
      gracefulShutdownPeriod - 停止時に待機するタイムアウト。
      戻り値:
      スペック

    • consumersPerQueue

      public AmqpClientInboundGatewaySpec consumersPerQueue(int consumersPerQueue)
      各キューは独自のコンシューマーで実行されます。このプロパティを設定すると、キューごとに複数のコンシューマーが作成されます。キューごとに concurrency として扱うこともできます。
      パラメーター:
      consumersPerQueue - キューごとのコンシューマー。
      戻り値:
      スペック

    • messageConverter

      public AmqpClientInboundGatewaySpec messageConverter(@Nullable MessageConverter messageConverter)
      デフォルトの SimpleMessageConverter を置き換える MessageConverter を設定します。null に設定した場合、AMQP メッセージはそのままメッセージペイロードに送信されます。応答メッセージは、ペイロードとして AMQP メッセージを返す必要があります。
      パラメーター:
      messageConverter - 使用する MessageConverter または null。
      戻り値:
      スペック

    • headerMapper

      public AmqpClientInboundGatewaySpec headerMapper(AmqpHeaderMapper headerMapper)
      リクエストヘッダーと応答ヘッダーをマップするには、AmqpHeaderMapper を設定します。
      パラメーター:
      headerMapper - 使用する AmqpHeaderMapper。
      戻り値:
      スペック

    • replyPostProcessor

      public AmqpClientInboundGatewaySpec replyPostProcessor(ReplyPostProcessor replyPostProcessor)
      応答 AMQP メッセージを生成する前に、ReplyPostProcessor を設定してメッセージを変更します。
      パラメーター:
      replyPostProcessor - 使用する ReplyPostProcessor。
      戻り値:
      スペック

    • replyExchange

      public AmqpClientInboundGatewaySpec replyExchange(StringSE exchange)
      応答を発行するための交換を設定します。replyQueue(String) とは排他的です。どちらも設定されていない場合は、リクエストメッセージの replyTo プロパティを使用して、応答を生成する場所を決定します。
      パラメーター:
      exchange - 交換機に返信を送信します。
      戻り値:
      スペック

    • replyRoutingKey

      public AmqpClientInboundGatewaySpec replyRoutingKey(StringSE routingKey)
      応答を発行するためのルーティングキーを設定します。replyExchange(String) と併用してください。どちらも設定されていない場合は、リクエストメッセージの replyTo プロパティを使用して、応答を生成する場所を決定します。
      パラメーター:
      routingKey - 返信を送信するためのルーティングキー。
      戻り値:
      スペック

    • replyQueue

      public AmqpClientInboundGatewaySpec replyQueue(StringSE queue)
      応答をパブリッシュするためのキューを設定します。replyExchange(String) とは排他的です。どちらも設定されていない場合は、リクエストメッセージの replyTo プロパティを使用して、応答を生成する場所を決定します。
      パラメーター:
      queue - 返信を送信するためのキュー。
      戻り値:
      スペック