問題タブ [rabbitmq-exchange]

パペット経由でrabbitmqをインストールしようとしています。puppetlabs-rabbitmqモジュールを使用しています。また、キューと交換を設定するセクションもありますNative Types。これらのネイティブ型の使用方法がわかりません。

rabbitmq インストールの私のコード:

次のエラーが表示されます。

注: これらのネイティブ タイプを除外すると、ウサギのインストールはうまく機能します。

、およびNative Typesを構成するにはどうすればよいですか?rabbitmq_queuerabbitmq_exchangerabbitmq_binding

Powershell を使用して Exchange を初期化しようとしています。DLQ を定義する必要があるため、次の構文を試しています。

次のエラーが表示されます。

このリンクを見ると、おそらくそれほど簡単ではないことがわかります。

引数フィールドはどこでも無視されます。引数を使用してキュー、交換、またはバインディングを作成することはできません。引数を持つキュー、エクスチェンジ、またはバインディングは、それらの引数を表示しません

キューに着信するすべてのメッセージが別のワーカーにルーティングされ、同時に特定のワーカーの 1 つと共有されるようにキューを定義したい

W(i) - 個別のメッセージを受信するワーカー

W(sp) - すべてのメッセージを受信する特別なワーカー

Q - キュー

' ------------------------------------------------------ Q--------- ----------------

|--------------------------- |--------------------- -------- |
|--------------------------- |--------------------- -------- |
W1,W(sp)-------------W2,W(sp)--------W3,W(sp)

ご覧のとおり、W1、W2、W3、W4 はすべて個別のワーカーであり、それぞれが通常のワーカーのように個別のメッセージを受け取ります。それぞれがキューから 1 つのジョブを受け取ります

ただし、各メッセージは交換 W(sp) のように共有する必要があります。どうすれば達成できますか。W(sp) が常にキューからすべてのイベントを受信できるように設定できるパラメーターはありますか?

あなたが助けることができればそれは素晴らしいことです

編集1

質問を理解するのが少し難しいことがわかりました。別のバージョンがあります

ジョブの並列処理を行いたいので、キューからジョブをラウンド ロビンで共有して、ジョブがコンシューマに一度だけ与えられるようにしたいと同時に、キューからすべてのジョブを取得する特別なコンシューマが必要です.

例えば：

消費者 - C1、C2、C3、C4

特別な消費者 - Csp

キュー - Q

Q の各ジョブは、C1、C2、C3、C4 のいずれかにブロードキャストされ、 Csp と共有される必要があります。したがって、Q からのジョブは、Csp と C(i) の 1 つとの間で共有されます。これにより、C1、C2、C3、C4 などのジョブを並列処理し、同時に Q の各ジョブを私のコンシューマ Csp で検証できます。

私は次の構成を持っています

anoter-queueとconsumer.queueに DLX を設定して、メッセージが1 秒後にconsumer.exchange-dlに移動されるようにしました。

another-exchange (直接)にバインドされているanother-queueでは、すべてが正常に機能します。consumer.exchange (トピック)に送信されたメッセージは DLX に移動されません。DLX のルーティング キー バインディングを試してみましたが、何も機能しませんでした。トピック交換のための DLX に関する落とし穴はありますか?

ありがとう

私は、フォード、ホンダ、日産の 3 つの異なるディーラーを持っています。彼らは皆、車とそのスペックについてメッセージを送ってくれます。

3 つのクエリ ABCCarCompany.E.Direct.Honda ABCCarCompany.E.Direct.Nissan ABCCarCompany.E.Direct.Ford または 1 つの ABCCarCompany.E.Direct.Cars を作成し、パラメータとして自動車メーカーを送信してもらいますか..プロとは3 つの質問対 1 つの ..

コンシューマー接続への次のリンクをたどりました http://pika.readthedocs.org/en/latest/examples/asynchronous_consumer_example.html

ワーカーを閉じて再起動するたびに、イベントが殺到するという奇妙な動作を観察します。理由がわからない。これらのイベントは基本的に、以前に渡されたイベントです。

私が理解しているのは、これらのイベントはまだ交換に保持されており、ワーカーを起動すると交換に接続され、すべてのイベントが再び取得されるということです。ところで私はファンアウト交換タイプを使用しています