Apache Camel+RabbitMQ-Camel定义自己的队列，不会从已经定义的队列中读取

Question

null

我通过一个简单的docker-compose文件运行这些实例：

version: '3'
services:
  rabbitmq:
    image: "rabbitmq:3.8.3"
    ports:
      - "5672:5672"
  rabbitmq-management:
    image: "rabbitmq:3-management"
    ports:
      - "15672:15672"

在那里,我通过管理面板创建了1个exchange和1个队列：

• main_exchange
• in_queue

from("rabbitmq:main_exchange?addresses=localhost:5672" +
            "&passive=true"+
            "&autoDelete=false" +
            "&declare=false" +
            "&queue=in_queue" +
            "&routingKey=in_queue_routing_key")
    .log("received from queue")
.to("file:done");

当我通过主交换将消息发布到in_queue时，什么也不会发生。骆驼路线不能接收信息。

我尝试了以下可能的解决方案：

>

将passive设置为true，因此RabbitMq本身不创建队列。

被动队列取决于RabbitMQ中已经可用的队列。

如果该选项为true，则camel声明交换和队列名称并将它们绑定在一起。如果该选项为false，camel将不会在服务器上声明exchange和队列名称。

代码示例：

from("file:test")
    .log("add to route")
.to("rabbitmq:main_exchange?addresses=localhost:5672" +
            "&passive=true"+
            "&autoDelete=false" +
            "&declare=false" +
            "&queue=in_queue" +
            "&routingKey=in_queue_routing_key");

但是在重新启动消费者路由（这个代码示例上面的路由）之后，消费者路由确实恢复了。

资料来源：

• https://camel.apache.org/components/latest/rabbitmq-component.html

Answer 1

看起来我发现了一个错误，Rabbitmq有一个管理+实例映像，而不是一个独立的管理映像。这导致运行了两个RabbitMQ实例，其中一个是我正在轮询并查看的，第二个是操作发生的地方，导致我没有找到任何东西，但应用程序仍在工作。

这是我的docker-compose文件：

version: '3'
services:
  rabbitmq-with-management:
    image: "rabbitmq:3-management"
    ports:
      - "5672:5672"
      - "15672:15672"

现在一切都按预期进行。