如何从RabbitMQ中删除队列绑定?

10

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

在我的设置中,这需要从该用户的队列中“取消绑定”已绑定的主题。

我正在使用pyamqplib,并且没有看到通过通道对象完成此操作的方法。是否有一种方法可以从队列中删除先前绑定的路由键?

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);
   }
}

2

在使用Python吗?

看起来像是pika 0.13有一个解绑方法

Original Answer翻译成"最初的回答"

queue_unbind(queue, exchange=None, routing_key=None, arguments=None, callback=None)


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接