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