クラス 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 - the advices to add
      戻り値:
      スペック

    • autoSettle

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

    • defaultRequeue

      public AmqpClientInboundGatewaySpec defaultRequeue(boolean defaultRequeue)
      Set the default behavior when a message processing has failed. When true, messages will be requeued, when false, they will be discarded. This option can be overruled by throwing AmqpRejectAndDontRequeueException or ImmediateRequeueAmqpException from the downstream flow. Default true.
      パラメーター:
      defaultRequeue - デフォルトで再キューする場合は true です。
      戻り値:
      スペック

    • gracefulShutdownPeriod

      public AmqpClientInboundGatewaySpec gracefulShutdownPeriod(DurationSE gracefulShutdownPeriod)
      Set a duration for how long to wait for all the consumers to shut down successfully on listener container stop. Default 30 seconds.
      パラメーター:
      gracefulShutdownPeriod - the timeout to wait on stop.
      戻り値:
      スペック

    • consumersPerQueue

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

    • messageConverter

      public AmqpClientInboundGatewaySpec messageConverter(@Nullable MessageConverter messageConverter)
      Set a MessageConverter to replace the default SimpleMessageConverter . If set to null, an AMQP message is sent as is into a message payload. And a reply message has to return an AMQP message as its payload.
      パラメーター:
      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)
      Set an exchange for publishing reply. Mutually exclusive with replyQueue(String) . If neither is set, the replyTo property from the request message is used to determine where to produce a reply.
      パラメーター:
      exchange - the exchange to send a reply.
      戻り値:
      スペック

    • replyRoutingKey

      public AmqpClientInboundGatewaySpec replyRoutingKey(StringSE routingKey)
      Set a routing key for publishing reply. Used only together with replyExchange(String) . If neither is set, the replyTo property from the request message is used to determine where to produce a reply.
      パラメーター:
      routingKey - the routing key to send a reply.
      戻り値:
      スペック

    • replyQueue

      public AmqpClientInboundGatewaySpec replyQueue(StringSE queue)
      Set a queue for publishing reply. Mutually exclusive with replyExchange(String) . If neither is set, the replyTo property from the request message is used to determine where to produce a reply.
      パラメーター:
      queue - the queue to send a reply.
      戻り値:
      スペック