28得票3回答
获取RabbitMQ队列中的消息数量

我们正在使用amqplib来发布/消费消息。我想能够读取队列中的消息数量(最好包括已确认和未确认的)。这将允许我向管理员用户展示一个良好的状态图表,并检测某个组件是否跟得上负载。 我在amqplib文档中找不到任何关于读取队列状态的信息。 有人可以指点我方向吗?

12得票5回答
等待一个RabbitMQ消息并设置超时时间

我想要向RabbitMQ服务器发送一条消息,并等待回复消息(在“reply-to”队列上)。当然,我不想永远等待,以防应用程序处理这些消息的进程关闭 - 需要设置超时。这听起来像是一个非常基本的任务,但我找不到实现的方法。我现在使用py-amqplib和RabbitMQ .NET client...

10得票3回答
如何从RabbitMQ中删除队列绑定?

我正在使用RabbitMQ通过主题将消息路由到感兴趣的订阅者。每个订阅者都有一个队列,我将队列绑定到他们感兴趣的主题上。我希望允许用户从他们的主题列表中删除项目。 在我的设置中,这需要从该用户的队列中“取消绑定”已绑定的主题。 我正在使用pyamqplib,并且没有看到通过通道对象完成此操...