如何避免ActiveMQ Artemis自动创建JMS队列并配置异常抛出

要实现队列存在则发送数据，队列不存在则抛异常的需求，核心是修改ActiveMQ Artemis连接工厂的配置，禁用其自动创建队列的默认行为，具体步骤如下：

1. 配置Artemis连接工厂，禁用自动创建队列 #

ActiveMQ Artemis的ActiveMQConnectionFactory默认会自动创建不存在的队列，我们需要将autoCreateQueues参数设为false，这样当尝试发送到未预先创建的队列时，客户端会直接抛出javax.jms.InvalidDestinationException异常。

Java配置方式（适用于Spring Boot/纯Java项目） #

import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.apache.camel.component.jms.JmsComponent;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.jms.ConnectionFactory;

@Configuration
public class ArtemisConfig {

    @Bean
    public ConnectionFactory artemisConnectionFactory() {
        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory();
        // 配置Artemis broker地址、用户名密码
        factory.setBrokerURL("tcp://localhost:61616");
        factory.setUser("admin");
        factory.setPassword("admin");
        // 关键：禁用自动创建队列
        factory.setAutoCreateQueues(false);
        // 若需要禁用自动创建主题，可添加下面一行
        // factory.setAutoCreateTopics(false);
        return factory;
    }

    // 将配置好的连接工厂绑定到Camel的JMS组件
    @Bean
    public JmsComponent jmsComponent(ConnectionFactory artemisConnectionFactory) {
        JmsComponent jmsComponent = new JmsComponent();
        jmsComponent.setConnectionFactory(artemisConnectionFactory);
        return jmsComponent;
    }
}

XML配置方式（适用于Spring XML项目） #

<!-- 配置Artemis连接工厂 -->
<bean id="artemisConnectionFactory" class="org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory">
    <property name="brokerURL" value="tcp://localhost:61616"/>
    <property name="user" value="admin"/>
    <property name="password" value="admin"/>
    <property name="autoCreateQueues" value="false"/>
</bean>

<!-- 绑定到Camel JMS组件 -->
<bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
    <property name="connectionFactory" ref="artemisConnectionFactory"/>
</bean>

2. 调整Camel路由（可选：添加异常处理） #

你的原有路由可以保持不变，但建议添加异常处理逻辑，以便在队列不存在时输出明确的错误提示：

from("file:C:/inputFolder?fileName=EventData.csv")
    .split(body().tokenize("\n"))
    .log("${body}")
    // 捕获队列不存在的异常
    .onException(javax.jms.InvalidDestinationException.class)
        .log("错误：队列myQueue不存在，无法发送数据")
        .handled(true) // 设为true则终止路由，设为false则继续传播异常
    .end()
    .to("jms:queue:myQueue");

注意事项 #

• 必须确保myQueue已经在Artemis Broker上预先创建（可以通过Broker的broker.xml配置文件添加，或者使用Artemis管理控制台手动创建），否则发送数据时会触发异常。
• 若同时需要处理主题，可添加factory.setAutoCreateTopics(false)禁用自动创建主题的行为。

内容的提问来源于stack exchange，提问作者Kuldeep Meena