rabbitmq-exchange

0熱

1答えて

ファイルからウサギmqにレコードを移し、キューからレコードを読み込み、サービスを呼び出します。拒否されたレコードについては、否定応答を送信してchannel.basicNackメソッドでキューに入れます。しかし、我々はサービス呼び出しの約3回の試みを行う必要があるという要件です。それから我々はキューからメッセージを削除する必要がありますが、何度も何度もサービスを呼び出し続けます。

0熱

1答えて

複数のrabbitTemplateを使用すると自動的にExchangeが作成されないRabbitMQのスプリングを使用する

CachingConnectionFactoryを使用していて、存在しない場合はキューと交換が自動的に作成されるようにしました。私は別のbean RabbitTemplateを作りました。その中に私は交換を設定しました。 @Bean public RabbitTemplate receiptRabbitTemplate() throws URISyntaxException { Rab

0熱

1答えて

RabbitMQ - アクセス制御：排他的/自動削除キューのみを許可する

ユーザーがログインできる典型的なSaaS製品を開発中です。は何かを実行します。フロントエンドはJS for webとAndroid for smartphonesです。フロントエンドは何かが更新されたときに通知を受け取って、自分のビューを更新することができます。私はこの目的のためにRabbitMQを使うことを考えています。私の提案では、各ユーザはそれぞれ独自の交換機を持っています。ユーザーにと

0熱

1答えて

のRabbitMQは、ルーティング動作

私はRabbitMQのを経由して2つの異なるqueueusにメッセージを公開しようとしているが、私は期待したものとして物事が動作しませんが、ここでは詳細です。ファンアウト、バインディングはQueue：Q1、Routingキー：key1、Queue：Q2、Routingキー：key2です。私のクライアント側で、私はこのコード var model = connection.CreateModel()

0熱

1答えて

Spring RabbitMQプロジェクトで複数の仮想ホストを使用するには？

私は、次の2つの設定クラスました：LocalRabbitConfigAとLocalRabbitConfigBクラスが別のバーチャルホストに接続はconnectionFactoryを定義することを @Configuration @EnableRabbit @Import({ LocalRabbitConfigA.class, CloudRabbitConfigA.class }) public

0熱

1答えて

信頼性の低いネットワーク環境でMassTransitを設定するにはどうすればよいですか？

私はRabbitMQと組み合わせてMassTransitの周りに頭を上げようとしています。基本的なコンセプトはテストプロジェクトで作業していますが、必要なものは次のとおりです。私のシステムには、実際の出来事（電話）に反応する1台以上のサーバーがあります。これらのイベントは、MassTransitとRabbitMQを使用して、RabbitMQホストとしてセットアップされた別のサーバーを介して1つ

0熱

1答えて

ウサギのmQメッセージがレディキューからUnackキューに移動

私は別のパブリッシャとコンシューマを持っています。パブリッシャとパブリッシュメッセージを開始します。私はコンシューマを開始し、問題はレディキューからメッセージを再キューに入れるあなたは、あなたが春AMQPを使用している場合 @Bean public org.springframework.amqp.rabbit.connection.Connection mqConnection() {

1熱

1答えて

RabbitMqメッセージを相関IDで1つのメッセージに集約する方法

私は、連続して実行する必要のあるコマンドのパイプラインを持ち、コマンドの中には並列（同じ相関ID）で実行する必要がある複数の操作が含まれているとします。パイプラインでさらに実行を進めるために、すべての並列操作がいつ実行されるのかを知る必要があると仮定しましょう。データベースのような外部データソースを使用せずに交換とキューを使用することで、RabbitMQだけでこの種のオーケストレーションを実現で

0熱

1答えて

リモートマシンのキューをパージしようとしましたrabbitmq

私はrabbitmqをポート15672のIPアドレス10.8.11.12を持つ別のマシンで稼働させていて、「hello」という名前のキューを持っています。私はそれがうまくを働いていると私は localhostをにキューをパージするrabbitmqctlのpurge_queue 次試してみましたCLI（コマンドラインインターフェイス）を使用して私のマシンからhelloキューを削除したいです私はc