クラス AmqpClientInboundChannelAdapterSpec

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

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

    • AmqpClientInboundChannelAdapterSpec

      public AmqpClientInboundChannelAdapterSpec(AmqpConnectionFactory connectionFactory, StringSE... queueNames)
      AmqpConnectionFactory と消費するキューに基づいてインスタンスを作成します。
      パラメーター:
      connectionFactory - AmqpConnectionFactory を接続する
      queueNames - 消費するキュー

  • 方法の詳細

    • initialCredits

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

    • priority

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

    • stateListeners

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

    • afterReceivePostProcessors

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

    • batchSize

      public AmqpClientInboundChannelAdapterSpec batchSize(int batchSize)
      ダウンストリームで単一のメッセージとして生成する前に収集する AMQP メッセージの数を設定します。デフォルトは 1 で、バッチ処理は行われません。
      パラメーター:
      batchSize - 使用するバッチサイズ。
      戻り値:
      スペック
      関連事項:

    • batchReceiveTimeout

      public AmqpClientInboundChannelAdapterSpec batchReceiveTimeout(long batchReceiveTimeout)
      バッチ収集処理のタイムアウトをミリ秒単位で設定します。このタイムアウトまたは batchSize(int) のどちらか早い方で、バッチは単一のメッセージとして解放されます。デフォルトは 30 秒です。
      パラメーター:
      batchReceiveTimeout - バッチ収集のタイムアウト。
      戻り値:
      スペック

    • taskScheduler

      public AmqpClientInboundChannelAdapterSpec taskScheduler(TaskScheduler taskScheduler)
      バッチリリースを監視するための TaskScheduler を設定します。
      パラメーター:
      taskScheduler - 使用する taskScheduler
      戻り値:
      スペック

    • adviceChain

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

    • autoSettle

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

    • defaultRequeue

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

    • gracefulShutdownPeriod

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

    • consumersPerQueue

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

    • messageConverter

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

    • headerMapper

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