消息广播通知

Question

我有它们被连接到的RabbitMQ牛仔服务器上运行的两个实例。我使用gen_bunny作为RabbitMQ客户端连接到RabbitMQ。

我可以从的RabbitMQ如果使用bunnyc消耗消息：消耗（）。不过为此我需要明确地引用这个方法。我想要的是在牛仔上绑定一个事件，只要队列中有一条消息，它就会自动通知牛仔。

是否有可能使用gen_bunny或其他二郎客户端？

Answer 1

得到它的工作...在bunnyc.erl源了几次以后。现在，在初始化函数我已经添加订阅功能，并START_LINK功能bunnyc.erl所以一旦没有在队列中的消息传递我的牛仔进程的进程ID，我可以把它在牛仔的websocket_info功能..

Answer 2

不知道关于gen_bunny，但你可以订阅排队官方二郎客户端（看http://www.rabbitmq.com/erlang-client-user-guide.html“订阅队列”一节）

据我了解，你需要从队列中通过的WebSockets发送消息客户端。所以你需要订阅在与客户端进行通信的过程中进行排队。而在收到“收到......结束”或handle_info消息（取决于实现）

加成

我看了gen_bunny源...年糕/ gen_bunny取决于年糕/ amqp_client其提供amqp_channel：认购/ 3（见https://github.com/mochi/amqp_client/blob/master/src/amqp_channel.erl#L177），你可以用它来订阅