【问题标题】:RabbitMQ: How to prevent QueueDeclare to automatically generate a new QueueRabbitMQ:如何防止QueueDeclare自动生成新Queue
【发布时间】:2015-04-12 14:08:39
【问题描述】:

使用 RabbitMQ,我正在做类似的事情:

channel.QueueDeclare(QueueName, true, false, false, null);

默认情况下,如果现有队列中没有一个与提供的名称匹配,RabbitMQ 会创建一个新队列。我想抛出一个异常。 这可能吗?

谢谢

【问题讨论】:

  • 你想实现什么?您是否尝试过使用被动声明?
  • 我只想使用队列而不声明它是否丢失。我将调查被动声明。谢谢
  • 如果队列丢失了,那么你必须声明它,没有办法绕过它。

标签: c# rabbitmq message-queue


【解决方案1】:

您可以绑定到现有队列而无需声明新队列。

try
{
    channel.QueueBind(queueName, exchange, routingKey);
}
catch (RabbitMQ.Client.Exceptions.OperationInterruptedException ex)
{
    // Queue not found
}

如果您尝试绑定的队列不存在则抛出异常的示例:

RabbitMQ.Client.Exceptions.OperationInterruptedException:AMQP 操作被中断:AMQP 关闭原因,由 Peer 发起,code=404,text="NOT_FOUND - no queue 'TestQueue' in vhost '/'",classId=50 , methodId=20, cause=

【讨论】:

    【解决方案2】:

    为此进行了被动声明。使用IModel.QueueDeclarePassive():

    model.QueueDeclarePassive("queue-name");
    

    如果队列已经存在,则不执行任何操作,否则引发异常。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2019-03-10
      • 2021-10-27
      • 2020-01-07
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多