使用嵌入式amqp swith spring boot和camel

Question

我想联调一个自定义的骆驼组件，因此需要一个嵌入的/在内存中的消息传递，我可以很容易地使用它来测试从/到endpoint。

我希望我能通过spring boot amqp starter实现这一点。我用这个例子作为开始，它具有以下依赖性：

 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<dependency>
  <groupId>org.apache.activemq</groupId>
  <artifactId>activemq-broker</artifactId>
</dependency>
<dependency>
  <groupId>com.fasterxml.jackson.core</groupId>
  <artifactId>jackson-databind</artifactId>
</dependency>
<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-spring-boot-starter</artifactId>
</dependency>

以及配置：

spring:
  activemq:
    broker-url: vm://embedded?broker.persistent=false,useShutdownHook=false
   // ...

这是有效的，当我在spring中使用常规侦听器注释时，我有一个使用模板的发送者和一个记录消息的消费者。

现在我更进一步，使用camel，但它不识别vm:embedded代理，而是尝试连接到tcp://localhost，它没有运行。

return new RouteBuilder() {
        @Override
        public void configure() throws Exception {
            from("activemq:foo").to("log:sample");

            from("timer:bar").setBody(constant("Hello from Camel")).to("activemq:foo");
        }
    };

如何配置activemq camel以使用嵌入式代理？

更新：

我对Spring Boot依赖项（1.5.9）和camel-Spring Boot依赖项（2.20.1）使用依赖项管理导入。

Answer 1

当您将它与Spring Boot一起使用时，这已在较新版本的Activemq-camel中得到修复。现在Activemq-camel组件将遵守spring.activemq.*设置的Spring启动配置。