如何将异步函数传递给amqplib通道＃消耗

Question

使用amqplib的我的nodejs代码几乎与recieve_logs_topic.js example 相同，它从RabbitMQ队列中读取并进行处理。示例中的处理函数是logMessage（），它打印要记录的消息。这是一个同步操作。我的处理器是基于异步和回调的。

展望的channel_model.js代码显示在函数体的评论：

// NB we want the callback to be run synchronously, so that we've 
// registered the consumerTag before any messages can arrive. 

能不能做到？

Answer 1

该示例中的代码也是异步的，但基于promise。如果您需要使用基于回调的API，请看这里：https://github.com/squaremo/amqp.node/tree/master/examples/tutorials/callback_api