amqp

1熱

1答えて

Amqpブローカには、メッセージが実際にブローカに届いた場合にのみ動作する永続性設定があります。ネットワーク障害が発生し、その後のクライアントクラッシュ/再起動メッセージが失われる可能性がある場合。クライアント（プロデューサ）がメッセージをディスクに保存するためのrabbitmqやactivemqやその他のメッセージングフレームワークには、クライアントがクラッシュしたりリブートされた場合に、未送信

0熱

2答えて

すべてのサービスが開始された後にstart node.js app

たとえば、私は2つのサービスを持っています：dbとキュー dbの後にサーバを起動し、amqpがサーバに接続する必要があります。今の私はこのserver.jsのようなものがあります。 let mongo = require('./server/db'); let qManager = require('./server/amqp'); mongo.connect(()=>{ qMa

0熱

1答えて

JMSを使用してAzureサービスバスにスケジュールメッセージを送信する方法

Azure Service Busにはスケジュールされたメッセージを送信する機能があります。 AMQPプロトコルと送信予定のmessagesesは、ここで説明：https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-amqp-request-response#message-operations スケジュー

2熱

1答えて

セラーのアップグレード（3.1 - > 4.1） - ピアによる接続のリセット

昨年はセロリを使用していましたが、従業員は約15名で、1-4の並行性が定義されています。最近、私たちは今、私たちは労働者のログの各1は、そのようなエラーに発生する可能性がありますどのような任意のアイデアで、次のエラーを持っているV3.1からV4.1 に私たちのセロリをアップグレード？ところで 2017-08-21 18:33:19,780 94794 ERROR Control command

1熱

1答えて

Python 3.6：クラスを使用せずにSelectConnectionアダプタを使用してpikaコンシューマを作成するにはどうすればよいですか？

私はpythonとpikaには新しく、数時間後に例外をスローし続けるBlockingConnectionアダプタを使用してキューから消費する問題にぶち当たっています。私は今、SelectConnection（非同期）アダプタを使用しようとしていますが、このアダプタタイプをクラス内で使用し、クラスベースのコードで作業するサンプルは、私の理解をはるかに超えています。 SelectConnection

1熱

1答えて

RabbitMQからphp-amqlibでメッセージを読むことができません

私はphp-amqplibを使用して、PHPとRabbitMQとのクライアントとサーバーの通信に取り組んでいます。私は正常に動作するように見えるプロデューサスクリプトを持っていますが、コンシューマは何も受信しません。キュー内のエントリをsudo rabbitmqctl list_queuesでチェックし、プロデューサを実行するたびにカウンタがインクリメントします。私の消費者はPHPエラーなし

0熱

2答えて

RabbitTemplateまたはAmqpTemplateを使用するのはどちらですか？

Spring Bootで書かれた以下のプログラムが正常に動作しています。しかし、問題は、RabbitTemplateとAmqpTemplateのどちらを使用すべきかわかりません。オンラインの例/チュートリアルの一部はRabbitTemplateを使用し、その他のものはAmqpTemplateを使用します。ベストプラクティスとどちらを使用するかをご案内してください。 @SpringBootAppl

1熱

1答えて

Python ActiveMQ：ActiveMQでpikaクライアントを使用することはできますか？

私が知っているように、ActiveMQはamqp://プロトコルをサポートしていますが、今はPython内でActiveMQインスタンスを接続したいと思っています。 pikaパッケージを入手することは可能ですか？ピカの文章を読んでいるうちに、RabbitMQと一緒に使うのがデザインだと思われました。それ以外の場合、私はどのプロトコルを使うべきですか？これはPythonのActiveMQにとって最

0熱

1答えて

Handle UnknownHostExceptionが正しくRabbitMQで自動回復できない

RabbitMQをRabbitMQ Client APIで手動で実装しているSpringアプリケーションを作成しました。接続ファクトリとコネクションが設定されている方法は、チュートリアルに似ています： public class Recv { private final static String QUEUE_NAME = "hello"; public static voi

3熱

1答えて

RabbitMQリクエストレスポンスメッセージ

私はJavaとSpring FrameworkでRabbitMQを使用していますが、プロデューサとコンシューマがあり、両方とも複数のインスタンスが実行されますが、プロデューサに送信される各リクエストは、その消費者は同じプロデューサ（要求を保持しているものとまったく同じもの）に返答することができるはずです。だから要件は次のとおりです。プロデューサーは、HTTPリクエストを受信するには、メッセージ