我在Camel的routeContext中定义了一个简单的路由(该路由将在多个路由中使用)。
<route id="sendToRabbitQueue">
<from uri="direct:sendToQueue" />
<convertBodyTo type="java.lang.String"/>
<setHeader headerName="rabbitmq.ROUTING_KEY">
<constant>my.routing.key</constant>
</setHeader>
<to uri="ref:genericRabbitEndpoint"/>
</route>
我有一个端点(在端点文件中定义)
<endpoint id="genericRabbitEndpoint" uri="rabbitmq://${rabbitmq.host}:${rabbitmq.port}/${rabbitmq.exchange.name}">
<camel:property key="autoDelete" value="false" />
<camel:property key="connectionFactory" value="#rabbitConnectionFactory" />
</endpoint>
是的 - 我已经看到 http://camel.apache.org/rabbitmq.html页面 - 这就是我在交换上设置标题的想法的地方。但是队列上没有发布任何消息。我显然忽略了一些事情,任何帮助将不胜感激。
最佳答案
所以这看起来有点像一个陷阱,答案与我没有包含在问题中的部分路线有关,因为我认为它不相关。
路由从 RabbitMQ 端点(上面未包含)开始。因此,交换器在到达时会设置一些 RabbitMQ header :
rabbitmq.ROUTING_KEY
rabbitmq.EXCHANGE_NAME
rabbitmq.DELIVERY_TAG
这些 header 在路由的整个生命周期中使用,并且当我尝试在不同的 RabbitMQ 端点上发布时,它们似乎会覆盖这些值。我解决的方法是引入一个可以去除标题的 bean。我认为这不是理想的行为......
public void stripRabbitHeaders(@Headers Map headers)
{
headers.remove("rabbitmq.ROUTING_KEY");
headers.remove("rabbitmq.DELIVERY_TAG");
headers.remove("rabbitmq.EXCHANGE_NAME");
}
关于java - Camel 未发布到 RabbitMQ 队列,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32380661/