【发布时间】:2012-03-30 01:16:52
【问题描述】:
我是 RabbitMQ 的新手。我昨天才开始。我在发送和消费东西方面做得很少。我注意到的是他们的文档,甚至在我读过的文章中,他们中的大多数都在以一种循环方式实现订阅部分以从队列中获取消息。我怎样才能使它成为事件驱动的?我想要完成的是,当一条消息被发送到队列时,它将引发并向接收者发出事件并对其进行处理。也许喜欢显示消息。
非常感谢您的回复。
最好的问候,
【问题讨论】:
我是 RabbitMQ 的新手。我昨天才开始。我在发送和消费东西方面做得很少。我注意到的是他们的文档,甚至在我读过的文章中,他们中的大多数都在以一种循环方式实现订阅部分以从队列中获取消息。我怎样才能使它成为事件驱动的?我想要完成的是,当一条消息被发送到队列时,它将引发并向接收者发出事件并对其进行处理。也许喜欢显示消息。
非常感谢您的回复。
最好的问候,
【问题讨论】:
应该使用 EventingBasicConsumer。我的网站上有一个示例,显示了它是如何使用的 RabbitMQ Events using EventingBasicConsumer
基本上它只是一个暴露 Received 事件的新消费者,因此您不需要阻止。
【讨论】:
一些示例使用这种循环样式,因为它更易于解释和理解。
您想使用IModel.BasicConsume 而不是BasicGet。有关示例,请参见 API Guide(搜索订阅和消费)。
【讨论】: