【问题标题】:How do you remove a queue binding from RabbitMQ?如何从 RabbitMQ 中删除队列绑定?
【发布时间】:2011-05-14 13:27:52
【问题描述】:

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

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

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

【问题讨论】:

    标签: rabbitmq amqp py-amqplib


    【解决方案1】:

    【讨论】:

      【解决方案2】:
      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);
         }
      }
      

      【讨论】:

        【解决方案3】:

        在 Python 中工作?

        在我看来 pika 0.13 有一个 unbind method

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

        【讨论】:

          猜你喜欢
          • 2013-11-23
          • 1970-01-01
          • 1970-01-01
          • 1970-01-01
          • 2015-05-06
          • 2012-07-12
          • 2022-01-20
          • 2011-10-08
          • 2015-12-20
          相关资源
          最近更新 更多