java - Apache Camel:将路由消息输出到AMQP

我是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:将路由消息输出到AMQP，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/35596632/