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();
});