node.js - node-amqp がメッセージを送信するまで待ちますか?

Question

次のコードを使用して、RabbitMQ にメッセージを送信するとします。

var amqp = require('amqp');
var connection = amqp.createConnection();
connection.on('ready', function() {
  connection.publish('foo', 'Hello');
  process.exit();
});

...その後、メッセージは送信されず、プロセスは終了します。を削除するprocess.exit()と、メッセージは送信されますが、プロセスは終了しません。

node-amqpがメッセージを送信したときに教えてもらうにはどうすればよいですか?

Answer 1

パブリッシュ機能でコールバックを使用します。コールバックで接続を終了し、終了します。

connection.publish('foo', 'hello', function(){
   connection.end();
   process.exit();
});