amqp

-2熱

1答えて

私はMQTTブローカーに手を加えてチャネルを作成し、それを購読していました。今日私はRabbitMqインターフェイスにログインし、 mqtt-subscription-1qos1とmqtt-subscription-2qos1の2つのキューを見つけました。私は2人がお互いに関係しているか分からないので、とても混乱しました。 MQTTはAMQPの上に構築されているので、キューを作成する理由は？

0熱

2答えて

RabbitTemplate.send（）はRabbitMQへのメッセージ配信を保証しますか？

メソッドrabbitTemplate.send(message)への呼び出しが（org.springframework.amqp.rabbit.core.RabbitTemplateクラスから）返されるとき、Spring AMQPを使用して、メッセージがRabbitMQクラスタで配信され、複製されていることを確認できますか？

0熱

1答えて

なぜ私のrabbitMQクライアントに接続できませんか？

TLSv1.2を使用してサーバーとRabbitMQ接続を作成しようとしていますが、java.net.SocketExceptionがあります。接続のリセットまたはjavax.net.ssl.SSLHandshakeException：致命的な警告を受け取りました：handshake_failure（この例外は変更されているようです無作為に）。私はTLSv1.0を持っていたときに動作しましたが、サ

1熱

1答えて

RabbitMQのAMQPクライアントからMQTTメッセージを購読しますか？

MQTT/WebMQTTプラグインを有効にしてRabbitMQノードを実行しています。すべてのMQTTプラグイン設定がデフォルト構成を使用します。さまざまなMQTTクライアントがMQTTチャネルにメッセージを送信しています。 MQTTチャネル名は、devices/{device_id_here}/{special_name_here} の形式に従います。MQTTのdevices/#/logsと

0熱

2答えて

golangとアクティブMQに接続

アマゾンMQ（アクティブMQ）が、それはAMQPと連携言うと、ゴーパッケージはここにありますhttps://github.com/streadway/amqpが、私は（ダイヤルしてみてください）私はそれを疑う Exception (501) Reason: "Exception (501) Reason: \"frame could not be parsed\"" このエラーが出ますこれはa

0熱

1答えて

org.springframework.amqp.AmqpIllegalStateException： 'キュー'が指定されていません。 RabbitTemplateの構成を確認してください

私はrabbitmqからメッセージを読み込んでOracleデータベースに書き込むアプリケーションを作っています。私は春のブートバッチを使ってメッセージを読むことができましたが、 "No 'キューが指定されていません"というエラーが表示されて終了しました。RabbitTemplateの設定を確認してください。 RabbitConfig.java @Configuration public clas

1熱

1答えて

RabbitMQ + Spring統合。キューサイズ1は、のみ削除するとき、私は今かのうである場合のRabbitMQと春の統合でこのアイデアを実装したいと思い

オーバーライド： 1つのキュー、1つのメッセージのcapatityと。コンシューマはこのメッセージを要求します。キューに存在する場合はメッセージが配信され、存在しない場合はnullまたはエラーが返されます。このメッセージ（キューに存在する場合）は、ダウンロードされたために削除されません。プロデューサが新しいメッセージをキューに入れたときにのみ削除されます。よろしくお願いいたします。このような

0熱

1答えて

なぜamqplibの消費関数を持つnodejsが閉じているのですか？

私はrabbitmqに接続するためにnodejs amqplibモジュールを使用します。私は消費関数がクロージャ関数になっているのを発見しましたが、なぜそれが理解できませんでした。私は閉鎖を使用しませんでした。私のコードは以下の通りです。私はreturnOKのcorrがまだ最初の値を取得することがわかりました。私はこの機能を2回発砲します。 corrは最初の値です。私はそれが奇妙だと思います

0熱

1答えて

RabbitMQとの接続解除後にApacheプロセスが終了しない

私のプロジェクトでメカニックServer Side Eventsを使用しようとしていました。（これはステロイドのロングポーリングのようなものです）「Sending events from the server」の例題は、美しく動作します。数秒後に切断されると、Apacheプロセスが強制終了されます。このメソッドは正常に動作します。 BUT！ RabbitMQを使用しようとすると、ブラウザからサ

0熱

1答えて

が一時的に後で

私はJavaのRabbitMQのクライアント（https://mvnrepository.com/artifact/com.rabbitmq/amqp-client）を使用して、私は次のシナリオを実装する必要がRabbitMQのメッセージを消費して停止し、再開：ウサギのメッセージを受信している間を、私は特定のキューからRabbitMQの消費量を一時停止する必要があるかもしれません私がデータを