node-amqp

6熱

1答えて

RabbitMQとnode-amqp：確認モードのExchangeで確認が行われない - なぜですか？

私はRabbitMQに依存するNode.jsアプリケーションを書いています。私はRabbitMQに接続するための選択ライブラリとしてnode-amqpを使用しています。私はRabbitMQのへの接続を確立したら、私はするつもりです最初のものは、交換を作成することです： var options = { autoDelete: false, confirm: true, durable: true,

0熱

2答えて

AMQPlib nodejsコンシューマタスクの同時実行

amqlibモジュールを使用して、rabbitmqとnodejsを使用してバックグラウンドタスク管理システムを構築しています。いくつかのタスクは実際にはCPUを消費します。そのため、私はそれらの多くを起動していて、少数のワーカーしか持たない場合、サーバが殺されることがあります。私のコンシューマが一度にこのキューの1つのタスクしか消費しないようにamqpキューを作成する方法があるかどうかは疑問で

1熱

1答えて

RxJS非同期サブスクライバ関数で観測可能

私はそれが簡単であると感じる何かをしようとしていますが、驚くほど難しいことを証明しています。私はRabbitMQキューを購読する機能を持っています。具体的には、これはここのChannel.consume関数です：http://www.squaremobius.net/amqp.node/channel_api.html#channel_consume サブスクリプションIDで解決された約束を返し

0熱

2答えて

MQRabbit Queueの最後にメッセージを入れる方法

私はRabbitMQからのメッセージを処理できる作業者に取り組んでいます。しかし、私はこれを達成する方法が不明です。エラーメッセージが表示され、処理中にエラーが発生した場合、どのようにメッセージをキューの最後に置くことができますか？私はnackや拒否を使用しようとしていますが、メッセージは常に最初の位置に再入力され、他のメッセージはフリーズします。メッセージが最初の位置になければならない理

0熱

1答えて

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

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

4熱

1答えて

公開するたびにチャンネル/接続を終了する必要がありますか？

Node.jsでamqplibを使用していますが、私のコードのベストプラクティスについては明確ではありません。基本的に、私の現在のコードでは、ノードサーバーが起動するときにamqp.connect()が呼び出され、各プロデューサと各コンシューマに対して異なるチャネルが使用されます。それが意味をなさないかどうかを知りたいのですが、メッセージを公開するたびにチャンネルを作成して公開して閉じる必要があ

0熱

2答えて

amqpで経路指定されていないメッセージを取得することはできますか？

RabbitMQ Web UIの使用現在のキューバインディングがないトピック交換に公開すると、rabbitmqはメッセージが公開されているがルーティングされていないと言います。 amqp.nodeを使用すると、キューをExchangeにバインドし、「＃」（すべて）を使用して消費を開始すると、何も取得できません。以前に公開されているが経路指定されていないメッセージが届きます。これは可能ですか？

0熱

1答えて

rabbitmq - コンシューマあたりのプリフェッチ数

node-amqpライブラリを使用してRabbitMQの複数のコンシューマを作成したいと考えていますが、prefetch-countオプションがコンシューマごとのカウントを参照するかどうかはわかりません。私は各消費者に、他の消費者に依存しない独自のプリフェッチ数を持たせたいと思います。ありがとうございました。

6熱

1答えて

amqp.nodeは接続のドロップを検出しません

クライアントがRabbitMQキューからメッセージを消費するsocket.ioサーバーを実行しているnode.jsスクリプトがあります。最近、Amazon AWSに移行しました.RabbitMQは2台のマシン（冗長インスタンス）のクラスタになりました。 AMQP接続は随時失われます（冗長VMを備えた高可用性環境から到着する制限であり、対処が必要です）。再接続を試みると、DNSはどのインスタンスを接

0熱

1答えて

メソッドを使用してすべてのメッセージを取得する方法は、lib amqp.nodeで消費されますか？

挨拶する人。 node.jsで非同期で手助けできますか？私がここにありRabbitMQとの仕事のために使用amqplib moduleだとRabbitMQのからのメッセージを与えるを消費方法、彼はを開始し、この後、約その方法最初のリターンの約束：この問題約束は始まる、RabbitMQからデータを得るためにコールバックをコールし、すべてのメッセージが私のノードjsアプリに送信される時を捕まえる方