spring-amqp

0熱

1答えて

リスナー（rabbitmq、spring-amqp）のプリフェッチカウントをリセットします

私はspring-amqpを使用しています。 ChannelAwareMessageListenerを実装するリスナーでプリフェッチ数をリセットする方法を教えてください。 public class TestListener implements ChannelAwareMessageListener { @Override public void onMessage(Mess

1熱

1答えて

現在のメッセージの前にすべてのメッセージとAckの現在のメッセージをナックします（rabbitmq、java）

channel.basicQos(1); while (true) { GetResponse res = channel.basicGet(TEST_QUEUE, false); if (res != null) { deliveryTag = res.getEnvelope().getDeliveryTag(); } // Handle

1熱

2答えて

@HystrixCommand私は@EnableCircuitBreaker</p> <p>と私の@SpringBootApplicationを注釈付き以外でフェイルオーバーを試してみたいしているバネの統合@InboundChannelAdapter

にfallbackMethodを呼び出していないが、AMQPブローカー（RabbitMQのを）始めたが、私のフェールオーバーの方法があります決して呼び出されません。どのようなアイデアですか？ package demo.sources.time; import java.text.SimpleDateFormat; import java.util.Date; import org.s

0熱

1答えて

RabbitMQメッセージのヘッダー 'amqp_consumerQueue'が見つかりません

Spring AMPQとRabbitListenerを使用して複数のキューからRabbitMQメッセージを読み取るアプリケーションがあります。このようなもの @RabbitListener(queues = {"#{'${rabbit.queues}'.split(',')}"}) public void processRabbitMessage(@Payload String data, @H

3熱

1答えて

シングルキュー、複数の@RabbitListenerが異なるサービス

は、それが単一@RabbitListener、例えばを持つことが可能ですオペレーション？これで、Jsonのオブジェクトがオブジェクトに変換されます（例：FindApplicationByIdRequest、またはPingRequest）。しかし、私はそれを取り戻すとき今、： @Override public FindApplicationByIdResponse findApplication

1熱

1答えて

RabbitMQ：なぜ再接続した後にチャンネルが開かないのですか？私のアプリの後

は私のアプリがRabbitMQのサーバーに再接続したときに、私は私が INFO ... Created new connection: [email protected] [delegate=amqp://******] しかしときアプリがログに表示、 ERROR ... o.s.a.r.c.CachingConnectionFactory : Channel shutdown: connec

0熱

1答えて

春の統合 - AmqpOutboundEndpointとRabbitTemplateの違い

AmqpOutboundEndpointのインスタンスを使用して、スプリング統合を使用して最初のAMQPパブリッシャを作成しようとしています。私はAmqpOutboundEndpointがRabbitTemplateのインスタンスを使用しているので、RabbitTemplateとAmqpOutboundEndPointの違いは何であるか理解していません。私はは私がに応じてルーティングキーを切

0熱

1答えて

春の統合ハンドラ・エラー - >確認-ACKチャンネル私がやりたい

：は、Webサービスからメッセージを受信はウサギ検証XMLにXMLメッセージを送りますXSDへ - >起動例外（間違った検証）Webサービスへ戻るカスタムエラーメッセージステップ1：Webサービスからのメッセージを受け取ります - > RESULT OK <ws:inbound-gateway id="ws-inbound-gateway" request-channel="

1熱

1答えて

Spring RecoveryCallbackでメッセージの詳細を取得

私はRabbitMQにメッセージを公開していますが、RabbitMQがダウンしたときにエラーを追跡したいと思います。復旧コールバックでRetryTemplateを追加しましたが、復旧コールバックはこのメソッドを提供します。getLastThrowable() RabbitMQがダウンしたときに失敗したメッセージの詳細を提供する方法がわかりません。（ドキュメントごとに「RecoveryCallba

1熱

2答えて

spring rabbitmqを使用して異なるキューでタイムアウト、再試行、または最大試行を設定する方法

各キューに対してこれらの設定を行うことはできますか。私はキュークラスで、それが可能であることがわかりましたので、私は、リトライ数が多い重要なキューが必要ですが、それほど重要で、私は再試行を設定しないキュー、試みなど public Queue newQueue(String name) { return new Queue(name, durable, exclusive, autoDel