java – 使用AMQP和RabbitMQ的Spring,使用可选的x-dead-letter-

发布时间：2020-12-15 01:42:26 所属栏目：大数据来源：网络整理

导读：我在RabbitMQ中创建了一个现有队列.它可以使用或不使用x-dead-letter-exchange参数创建.我正在使用RabbitTemplate在Spring中创建此队列的使用者.当我声明队列时,我不想指定x-dead-letter-exchange参数.我希望模板以某种方式表现出来或不关心.我从我的消费者

我在RabbitMQ中创建了一个现有队列.它可以使用或不使用x-dead-letter-exchange参数创建.我正在使用RabbitTemplate在Spring中创建此队列的使用者.当我声明队列时,我不想指定x-dead-letter-exchange参数.我希望模板以某种方式表现出来或不关心.我从我的消费者那里抛出AmqpRejectAndDontRequeueException以指示错误消息,但是我希望队列的创建者负责决定是否为被拒绝的消息创建交换和队列.

这是我在bean中声明队列的bean：

@Bean
Queue queue() {
    Map


这工作正常,但当队列的创建者决定不使用死信功能时,我看到以下错误：

Channel shutdown: channel error; protocol method: #method

消息有点长,它继续告诉我哪一方有哪个x-dead-letter-exchange(没有或交换名称).我尝试了不同的组合(例如,创建具有交换的队列,而不是在Spring中指定它或在没有交换的情况下创建队列并在Spring中指定它),只是为了看到此消息的不同变体.
如何声明队列以便它只接受队列中已设置的任何参数？


最佳答案
正如你在spring docs中看到的那样：RabbitMQ代理不允许声明具有不匹配参数的队列.所以你不能这样做.
在RabbitMQ Java API中,有一种方法可以检查队列是否已经存在：queueDeclarePassive.
如果Spring AMQP API提供了类似的功能,您可以在尝试声明队列之前使用它.
                        （编辑：李大同）
【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!