【问题标题】:Wait until node-amqp has sent a message?等到 node-amqp 发送消息?
【发布时间】:2013-09-02 13:19:33
【问题描述】:

如果我使用以下代码向 RabbitMQ 发送消息:

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

...然后消息永远不会发送,进程就退出了。如果我删除process.exit(),则消息已发送,但进程永远不会退出。

我如何让 node-amqp 在它发送消息时告诉我?

【问题讨论】:

  • 我的回答对您有帮助吗?如果是这样,你能关闭这个问题吗? @罗杰

标签: node.js node-amqp


【解决方案1】:

publish function 中使用回调。在回调中结束连接并退出。

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

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2019-08-29
    • 1970-01-01
    • 2017-01-19
    • 1970-01-01
    • 2012-08-09
    • 2013-08-31
    • 1970-01-01
    相关资源
    最近更新 更多