10

我正在使用 RabbitMQ 按主题将消息路由到感兴趣的订阅者。每个订阅者都有一个队列，我将队列绑定到他们感兴趣的主题。我想允许用户从他们的主题列表中删除一个项目。

在我的设置中，这将需要从该用户的队列中“解除绑定”绑定主题。

我正在使用 pyamqplib，但我没有看到通过通道对象执行此操作的方法。他们是一种从队列中删除先前绑定的路由键的方法吗？

4

3 回答 3

5 
public void unsubscribe(String queuename, String topic) throws IOException
{
   ConnectionFactory factory = new ConnectionFactory();
   factory.setHost(MQ_HOST);
   factory.setPort(MQ_PORT);

   Connection connection = factory.newConnection();
   Channel channel = connection.createChannel();
   try
   {
      channel.exchangeDeclarePassive("Channel name");
      channel.queueUnbind(queuename, "Channel name", topic);
   }
   finally
   {
      handleClose(connection, channel);
   }
}
于 2011-04-11T19:06:26.640 回答
2

在 Python 中工作？

在我看来 pika 0.13 有一个unbind 方法：

queue_unbind(queue, exchange=None, routing_key=None, arguments=None, callback=None)
于 2019-03-03T17:56:07.147 回答
1

做这个

如何有选择地从 AMQP（RabbitMQ）队列中删除消息？

解决你的问题？

于 2010-12-03T11:44:35.883 回答