我是 Apache Camel 的新手,正在寻找一种将路由输出定向到 AMQP 的方法。
我可以自己编写一个例程发送到 AMQP,但我正在寻求建议,在声明路由时如何使用 Camel .to() 来完成它?网上很难找到完整的例子。
我需要做什么:
- 配置 amqp 路由以发送输出(服务器凭据等)
- 确保该路线可访问,因为我想处理配置错误问题。
- 我需要发送 JSON。我是否必须将 POJO 作为字符串编码为 json,或者我可以使用一些自动转换吗?
我想做的所有事情都不涉及 XML 配置,而是基于注释或代码。
最佳答案
以下是如何执行此操作的示例:
from("direct://PublishToRabbitMQ")
.setHeader("rabbitmq.ROUTING_KEY", constant("SOMEROUTINGKEY"))
.setHeader("rabbitmq.EXCHANGE_NAME",constant("EXCHANGE_NAME"))
.setHeader("timestamp", constant(new Date(System.currentTimeMillis())))
.doTry()
.to("rabbitmq://localhost/EXCHANGE_NAME/?exchangeType=Topic&autoDelete=false&durable=false")
.convertBodyTo(String.class)
.end();
添加或删除参数以满足您的需要。
关于java - Apache Camel : output route message to AMQP,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/35596632/