RabbitMQ stomp autodelete queue - 先决条件失败

Question

我正在编写使用 STOMP 进行通信的应用程序。服务器端使用 Spring Boot 2.1.7 编写，并作为外部代理使用 RabbitMQ 3.7.1。在客户端，我使用的是 StompJS。

当客户端订阅用户目的地时，例如。 /user/queue/some-queue Spring 会将其映射到 /queue/some-queue-{sessionID} 并且 RabbitMQ 创建具有相应名称的 queue。

订阅时，我添加了 header {'auto-delete': true}，如此处指定 RabbitMQ Stomp Docs，并在 RabbitMQ 中创建了自动删除 queue。

当我尝试以

身份向用户发送消息时出现问题

simpTemplate.convertAndSendToUser('user', '/queue/some-queue', message)

Spring 正确翻译了 queue 名称，但 rabbitmq 响应错误

PRECONDITION_FAILED - inequivalent arg 'auto_delete' for queue

我该怎么做才能解决这个问题？

Answer 1

我想我找到了解决办法。如果我添加在订阅期间定义的相同 headers，发送消息时，它将正常工作。

示例如下：

Map<String, Object> headers = new HashMap<>();
headers.put("auto-delete", "true");
simpMessagingTemplate.convertAndSendToUser("some-user", "/queue/some-queue", "Test payload", headers);

RabbitMQ stomp autodelete queue - 先决条件失败

RabbiMQ stomp auto delete queue - Precondition failed

stomp

rabbitmq

spring-rabbit