spring-rabbitmq

    1

    1答えて

    私はウサギの送信者と受信者を持つ簡単なスプリングブートアプリケーションを持っています。私は、受信者が同じメッセージを受信したかどうかを確認するために、受信者テストを書いて、Junitクラスルール(RabbitContainerRule)としてrabbitmq dockerインスタンスを実行してから、rabbitTemplateを使用してメッセージを送信します。しかし、私は次の例外取得しています:私

    0

    2答えて

    herokuには1つのサービスが導入されています。私のサービスはクラウドメッセージサービスとしてcloudamqpを使用します。私のローカルenv私の接続で実行されている私のサービスが成功し、私はこのエラーが見つかりませんでした。 私はherokuに私のサービスを配備するとき、私はこのエラーを持っています。 2017-10-30T06:03:05.231416+00:00 app[web.1]:

    0

    1答えて

    3ノードRabbit MQのセットアップがあります。実行時にすべてのキューが作成されています。 私はその後、キューを反映していない特定のキューは考えNode1で作成され、私はそれを確実にする方法として、その後春AMQPクライアントを使用する場合は、ノード2とノード3今 に存在しない場合ノード1で提供されていますQUEUE1は、それは常に他の方法は、任意のノード上で作成された各キューはに複製されます

    0

    1答えて

    私は、私のspringとrabbitmqとの統合状況があります。メッセージはキューに送信されますが、準備完了状態では終了し、未確認状態では1つになりますが、コンシューマはそれらを取得しません。 のTHX XML設定は、このようなものです:サーバー上 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="

    0

    3答えて

    春ウサギのバージョン:1.7.4.RELEASE これは私のコードです: @Configuration public class RabbitmqConfiguration { public RabbitmqConfiguration(RabbitTemplate rabbitTemplate,ConfirmCallback confirmCallback) throws Excep

    0

    1答えて

    上のバーチャルホストでノーキュー私はRabbitMQのは、この構成のクラスで構成された春のブートアプリケーションを起動しようとしている: @Configuration public class RabbitConfig implements RabbitListenerConfigurer { public static final String AMQP_EXCHANGE_NAME

    0

    1答えて

    いくつかの異なるサーバーの単一のインスタンスから多数のクライアントにメッセージを送信する必要のある一連のTomcat/Springアプリケーションがあります。各サーバーインスタンスには、独自の交換セットがあります。エクスチェンジはサーバによって宣言され、各クライアントによって生成され、それらのエクスチェンジにバインドされた匿名キューが宣言されます。私は匿名キューを使用しています。なぜなら、あらかじ

    0

    1答えて

    私はクライアントにcontent_type application/jsonを提供する必要はありませんが、デフォルトにしています。私はこれを働かせた。 また、別の例と組み合わせて、ConditionalRejectingErrorHandlerからカスタムisFatal(Throwable t)を実装しようとしました。カスタムエラーハンドラを起動させることはできますが、それでもcontent_ty

    0

    1答えて

    にバインド、送信していない私は、次のようにメッセージを送信しようとした: rabbitTemplate.convertAndSend("my.exchange", "my.queue", "Test Message"); を、次のようにメッセージを受信しようとした: @RabbitListener(bindings = @QueueBinding(value = @Queue(value =