クラスの使用
org.springframework.integration.amqp.dsl.AmqpClientInboundChannelAdapterSpec
AmqpClientInboundChannelAdapterSpec を使用するパッケージ
org.springframework.integration.amqp.dsl 内の AmqpClientInboundChannelAdapterSpec 使用
修飾子と型メソッド説明AmqpClientInboundChannelAdapterSpec.adviceChain(Advice... advices) Adviceインスタンスをプロキシメッセージリスナーに設定します。AmqpClientInboundChannelAdapterSpec.afterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors) 受信したばかりのメッセージに適用するMessagePostProcessorインスタンスを追加します。AmqpClientInboundChannelAdapterSpec.autoSettle(boolean autoSettle) 下流フローの手動決済のために確認応答コールバックをメッセージヘッダーに伝播するには、falseに設定します。AmqpClientInboundChannelAdapterSpec.batchReceiveTimeout(long batchReceiveTimeout) バッチ収集プロセスの実行時間に対するタイムアウトをミリ秒単位で設定します。AmqpClientInboundChannelAdapterSpec.batchSize(int batchSize) ダウンストリームで単一のメッセージとして生成する前に収集する AMQP メッセージの数を設定します。AmqpClientInboundChannelAdapterSpec.consumersPerQueue(int consumersPerQueue) 各キューは独自のコンシューマーで実行されます。このプロパティを設定して、キューごとに複数のコンシューマーを作成します。AmqpClientInboundChannelAdapterSpec.defaultRequeue(boolean defaultRequeue) メッセージ処理が失敗した場合のデフォルトの動作を設定します。AmqpClientInboundChannelAdapterSpec.gracefulShutdownPeriod(DurationSE gracefulShutdownPeriod) リスナーコンテナーの停止時にすべてのコンシューマーが正常にシャットダウンするまで待機する期間を設定します。AmqpClientInboundChannelAdapterSpec.headerMapper(AmqpHeaderMapper headerMapper) リクエストヘッダーをマップするにはAmqpHeaderMapperを設定します。AmqpClient.inboundChannelAdapter(AmqpConnectionFactory connectionFactory, StringSE... queueNames) 初期 AmqpClientInboundChannelAdapterSpec を作成します。AmqpClientInboundChannelAdapterSpec.initialCredits(int initialCredits) AMQP 受信者に付与する初期クレジット数。AmqpClientInboundChannelAdapterSpec.messageConverter(@Nullable MessageConverter messageConverter) デフォルトのSimpleMessageConverterを置き換えるためにMessageConverterを設定します。AmqpClientInboundChannelAdapterSpec.priority(int priority) コンシューマーの優先。AmqpClientInboundChannelAdapterSpec.stateListeners(com.rabbitmq.client.amqp.Resource.StateListener... stateListeners) Resource.StateListenerインスタンスをコンシューマーに追加します。AmqpClientInboundChannelAdapterSpec.taskScheduler(TaskScheduler taskScheduler) バッチリリースを監視するためのTaskSchedulerを設定します。