如何配置ActiveMQ-Camel以使用Spring Boot中的嵌入式消息代理？

你遇到的核心问题是Spring Boot自动配置的ActiveMQ连接工厂没有被Camel的ActiveMQ组件自动复用，导致Camel默认尝试连接tcp://localhost:61616而非你配置的VM嵌入式代理。下面提供两种可行的解决方案：

方案一：复用Spring的ConnectionFactory（推荐） #

Spring Boot的spring-boot-starter-activemq已经帮你创建了ActiveMQConnectionFactory实例，我们只需要把它绑定到Camel的ActiveMQComponent上，让Camel使用这个预配置的连接工厂即可。

创建一个配置类：

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.camel.component.activemq.ActiveMQComponent;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class CamelActiveMQConfiguration {

    @Autowired
    private ActiveMQConnectionFactory springActiveMQConnectionFactory;

    @Bean(name = "activemq")
    public ActiveMQComponent activeMQComponent() {
        ActiveMQComponent component = new ActiveMQComponent();
        // 绑定Spring自动配置的连接工厂
        component.setConnectionFactory(springActiveMQConnectionFactory);
        return component;
    }
}

配置完成后，Camel路由里的activemq:foo端点就会自动使用这个组件，从而连接到你指定的VM嵌入式代理。

方案二：直接配置Camel的ActiveMQ组件参数 #

如果你不想手动绑定连接工厂，也可以直接在Spring配置文件中指定Camel ActiveMQ组件的broker-url，和Spring的ActiveMQ配置保持一致：

application.yml配置示例： #

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

补充：确认依赖完整性 #

请确保你已经引入了Camel ActiveMQ的starter依赖，否则Camel无法识别activemq:端点：

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-activemq-starter</artifactId>
</dependency>

你的现有依赖中仅包含camel-spring-boot-starter，它不会自动引入ActiveMQ组件的starter，因此需要手动添加。

这两种方案都能解决你的问题，方案一的优势是复用Spring的连接工厂，避免配置重复，更符合Spring Boot的自动配置理念。

内容的提问来源于stack exchange，提问作者Jan Galinski