rabbitmq

0熱

1答えて

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

0熱

1答えて

AMQPのassertQueueのAPIドキュメントの

を意味する接続、それは述べて：が存在するようにキューをアサートします。この操作は、同一の引数が与えられたときは等価です。ただし、キューがすでに存在していても異なるプロパティ（引数フィールドに指定されている値は、ボルケーティングの目的でカウントされている場合とカウントされていない場合があります。 http://www.squaremobius.net/amqp.node/channel_api.h

0熱

1答えて

RabbitMQでAckをC＃で使用するには？

RabbitMQを使用してキュー内のメッセージを取得しています。一つずつ。これは私のコードの抜粋です： var data = channel.BasicGet(queue, true); if (data != null) message = System.Text.Encoding.UTF8.GetString(data.Body); else

0熱

1答えて

pika（pythonクライアント）を使用してRabbitMQでMQTTメッセージをパブリッシュ/サブスクライブする

私は既存のRabittMQサーバーをセットアップしており、MQTTプラグインがmqttメッセージをパブリッシュ/サブスクライブできるようにしました。既存のキューメッセージを処理するpikaクライアントがあります。今、私は同じpika on_message（）ハンドラを使ってmqttメッセージを処理したいと考えています。 eclipse pahoクライアント上でmqttメッセージを発行して購読する

0熱

1答えて

rabbitmqctlは、私は私のドッキングウィンドウ-compose.ymlでこの設定を持っているドッキングウィンドウ

にエラーを返します。しかし、時にサーバーが起動され、私は次のエラーましrabbitmqctlを使用するコンテナを入力します。私は欠けている何 rabbitmqctl list_queues Error: unable to connect to node [email protected]: nodedown DIAGNOSTICS =========== attempted to c

0熱

2答えて

Spring-Boot/AMQP - 処理されるメッセージの上限数

私はスプリングブートAMQPライブラリを使用して、スプリングブートアプリケーションを用意しています。のpom.xml： <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> は、どのよ

0熱

1答えて

耐久性と一時的なサブスクリプション

RabbitMQとMassTransitを使用したpub/subメッセージングを使用して複数の.Netモジュールを統合しています。メッセージサブスクリプションのほとんどは耐久性があります。しかし、一部は一時的である。消費者が死亡した場合、メッセージは保存されず、すでにキューに入れられたメッセージは破棄される。各モジュールでは、2つの受信エンドポイントで1つのバスを作成します。 1つは、耐久性のあ

0熱

1答えて

RabbitMQ：新しいメール通知モデル

私はウェブメールサーバを作成しています。私はクライアントへの新しいメール通知にウェブソケットを使用します。新しい電子メールがサーバーに到着すると、その特定の用途についてすべてのWebクライアントに通知する必要があります。私。ユーザは複数のブラウザウィンドウを開くことができる。これをrabbitmqでどのようにモデル化することができますか？私は、リソースを効率的に聞こえない、またはファンアウト

0熱

1答えて

メッセージを送信するためのRabbit MQブロッキングコールで、メッセージの制限値を超過するか、メッセージサイズ制限を超える正しい返信コードが返されることを確認してください。

こんにちは、私はウサギmqの簡単な解決策を探しています。以下はウサギの設定です。はウサギサーバは、耐久性のあるオプション付きタイプトピックのやり取り（myexchange）を作成開始。耐久オプションとx-max-length-bytesを4に設定し、x-max-lengthを2に設定してキュー（myqueue）を作成します。 myexchangeをmyqueueにバインドします。 aqmp

0熱

1答えて

rabbitmq ldap私はショートネームとしてログインを使用させません

私はrabbitmq ldapを私のために働かせようとしています。 user_dn_lookup_attributeをsAMAccountNameに設定し、dn_lookup_baseをDC = COMPANY、DC = comに設定した場合、user_dn_pattern、$ {username}@COMPANY.COMは私のためには機能しません。その場合、ログインがjoesmoの場合、ldap