阿帕奇骆驼+ RabbitMQ。端点未创建

Question

我创建了一个项目，它只包含 rabbitmq 的路由设置。

<route>
    <from uri="rabbitmq:localhost/test_out_ex?queue=test_out&amp;autoDelete=false&amp;username=admin&amp;password=admin"/>
    <to uri="rabbitmq:localhost/test_in_ex?queue=test_in&amp;autoDelete=false&amp;username=admin&amp;password=admin"/>
</route>

我在 tomcat 上运行它，Camel 只创建“from”-endpoint，而不是“to”（我在 rabbitMq Web 界面中查看）。为什么？因为，“to”没有消费者？

更多细节：

问题是消息没有保存在输出消息队列中。正常情况，应用已经发送消息到队列，此时消费者还没有上线，所以应该保存消息，直到消费者连接。

所以，我定义了简单的路由并将其部署在 tomcat 上，我还部署了 Jolokia 项目以通过 Hawtio 监控我的骆驼上下文。 Hawtio 向我展示了该路线已创建并由两个端点组成。然后我通过 RabbitMq 网络界面将消息发布到“test_out”。 Hawtio 告诉我，它到达了 'test_in' 队列，但在 RabbitMq 网络界面（或 rabbitmqctl）中，'test_in' 队列不存在，所以在服务器重新启动后消息消失了。

Answer 1

我们需要过滤从 test_out 路由到 test_in 时可能导致一些麻烦的消息头。

<route>
    <from uri="rabbitmq:localhost/test_out_ex?queue=test_out&amp;autoDelete=false&amp;username=admin&amp;password=admin"/>
    <removeHeader pattern="rabbitmq.*"/>
    <to uri="rabbitmq:localhost/test_in_ex?queue=test_in&amp;autoDelete=false&amp;username=admin&amp;password=admin"/>
</route>