spring-boot - Rabbitmq spring java配置与apache RouteBuilder

Question

我想用rabbitmq和apache RouteBuilder配置spring boot应用程序，谁能建议我怎么做

标签： spring-bootrabbitmq

Answer 1

你提到 Apache camel RouteBuiler吗？如果你说是，你可以使用Apache camel 从 2.12 版本开始提供的RabbitMQ 组件。有关更多详细信息，请查看我的示例代码：

<!-- language: lang-java -->

@Component
public class MyRoute extends RouteBuilder {
    @Override
    public void configure() throws Exception {
    // listen from exchange and log to console
        from("rabbitmq:topic_logs2?" +
            "vhost=myvhost&hostname=localhost&portNumber=5672" +
            "&username=myname&password=mypassword" +
            "&exchangeType=topic&autoDelete=false&queue=my_queue&routingKey=test.log")
        .log("From RabbitMQ: ${body}");
    }
}