如何配置Apache Camel让Spring Boot对接带认证的ActiveMQ生效？

以下是针对性的排查和解决步骤：

1. 确认配置项前缀是否正确 #

Spring Boot整合Camel时，必须使用camel.component.activemq.作为配置前缀，而非原生ActiveMQ的activemq.前缀。检查你的application.properties是否符合格式：

# ActiveMQ Broker地址
camel.component.activemq.broker-url=tcp://localhost:61616
# 自定义用户名
camel.component.activemq.username=your-custom-user
# 自定义密码
camel.component.activemq.password=your-custom-pass

2. 检查组件初始化代码是否覆盖配置 #

如果是手动创建ActiveMQComponent实例，确保从配置文件注入参数，避免硬编码默认值：

@Configuration
public class CamelActiveMQConfig {
    @Value("${camel.component.activemq.broker-url}")
    private String brokerUrl;
    @Value("${camel.component.activemq.username}")
    private String username;
    @Value("${camel.component.activemq.password}")
    private String password;

    @Bean
    public ActiveMQComponent activeMQComponent() {
        ActiveMQComponent component = new ActiveMQComponent();
        component.setBrokerURL(brokerUrl);
        component.setUsername(username);
        component.setPassword(password);
        return component;
    }
}

注意：若代码中硬写component.setUsername("admin")，会直接覆盖配置文件的值。

3. 排查配置优先级冲突 #

Spring Boot存在多配置源优先级（环境变量>系统属性>application.properties），可通过打印配置值验证是否被覆盖：

@Autowired
private Environment env;

@PostConstruct
public void verifyConfig() {
    System.out.println("ActiveMQ 实际读取的用户名: " + env.getProperty("camel.component.activemq.username"));
    System.out.println("ActiveMQ 实际读取的密码: " + env.getProperty("camel.component.activemq.password"));
}

如果输出不是你配置的值，说明有更高优先级的配置源生效。

4. 检查路由端点的硬编码配置 #

若路由中直接指定了端点的账号密码，会覆盖全局配置：

// 错误示例：硬编码账号会覆盖全局配置
from("activemq:queue:myQueue?username=admin&password=admin")
    .to("...");

改为使用全局配置或占位符引用：

// 正确方式：复用全局配置
from("activemq:queue:myQueue")
    .to("...");

// 或显式引用配置文件值
from("activemq:queue:myQueue?username=${camel.component.activemq.username}&password=${camel.component.activemq.password}")
    .to("...");

5. 验证ActiveMQ Broker端的用户配置 #

确保Broker端已创建对应的用户并赋予权限，例如在activemq.xml中配置：

<plugins>
    <simpleAuthenticationPlugin>
        <users>
            <authenticationUser username="your-custom-user" password="your-custom-pass" groups="users,admins"/>
        </users>
    </simpleAuthenticationPlugin>
</plugins>

若Broker端不存在该用户，即使Camel配置正确也会触发认证错误。

内容的提问来源于stack exchange，提问作者Om Prakash