私はRabbitMQに依存するNode.jsアプリケーションを書いています。私はRabbitMQに接続するための選択ライブラリとしてnode-amqpを使用しています。RabbitMQとnode-amqp:確認モードのExchangeで確認が行われない - なぜですか?
私はRabbitMQのへの接続を確立したら、私はするつもりです最初のものは、交換を作成することです:
var options = { autoDelete: false, confirm: true, durable: true, type: 'direct' };
connection.exchange('myExchange', options, function (myExchange) {
// ...
});
これは完璧に動作します。ご覧のとおり、私はconfirm: true
を使用して交換を作成していますので、その後交換が確定モードになることを期待しています。私はメッセージを公開しよう一度
var options = {};
myExchange.publish('', { data: 'foobar' }, options, function() {
// ...
});
問題はpublish
機能のコールバックが呼び出されないということです - メッセージが正常に公開されましたが、(私はRabbitMQの者の中に見ることができるようにウェブ管理ツール)。
私は間違った方法で確認モードを理解しましたか?これはnode-amqpのバグですか?
すべてのヘルプは、適切なGitHub issueに答え
これはnode-amqp version 0.2.0で修正されているようです。公開されたnpmのバージョンが私のために働いています。 – chevett