java - Apache Camel : output route message to AMQP

Question

我是 Apache Camel 的新手，正在寻找一种将路由输出定向到 AMQP 的方法。

我可以自己编写一个例程发送到 AMQP，但我正在寻求建议，在声明路由时如何使用 Camel .to() 来完成它？网上很难找到完整的例子。

我需要做什么:

1. 配置 amqp 路由以发送输出(服务器凭据等)
2. 确保该路线可访问，因为我想处理配置错误问题。
3. 我需要发送 JSON。我是否必须将 POJO 作为字符串编码为 json，或者我可以使用一些自动转换吗？

我想做的所有事情都不涉及 XML 配置，而是基于注释或代码。

Answer 1

以下是如何执行此操作的示例:

    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();

添加或删除参数以满足您的需要。