Artemis ActiveMQ + MDB长任务：消息重发前等待时长配置问询

首先明确回答：你看到的5分钟等待时长完全可以配置，它对应ActiveMQ Artemis的consumer-idle-timeout参数，默认值就是300000毫秒（5分钟）。

为什么会触发重发？ #

当你的MDB在执行长任务时（比如你测试用的10分钟休眠），Auto-acknowledge模式下只有onMessage方法执行完毕才会自动向Broker发送确认。如果这段时间超过了consumer-idle-timeout设置的值，Broker会认为这个消费者已经失效（长时间没有交互），于是将未确认的消息重新投递，这就是你日志里看到的5分钟后重发的原因。

具体配置方法 #

1. 全局配置（对所有消费者生效）

在WildFly的messaging-activemq子系统中，给server节点添加全局消费者配置，调整超时时间：

<subsystem xmlns="urn:jboss:domain:messaging-activemq:4.0">
    <server name="default">
        <!-- 保留你已有的in-vm连接器、接收器、队列配置 -->
        <in-vm-connector name="in-vm" server-id="0"/>
        <in-vm-acceptor name="in-vm" server-id="0">
            <param name="buffer-pooling" value="false"/>
        </in-vm-acceptor>
        <jms-queue name="MyJobsQueue" entries="java:/jms/MyJobsQueue" />
        
        <!-- 添加全局消费者超时配置 -->
        <consumer-settings>
            <consumer-setting match="#">
                <!-- 这里设置为10分钟（600000毫秒），根据你的实际任务时长调整 -->
                <consumer-idle-timeout>600000</consumer-idle-timeout>
            </consumer-setting>
        </consumer-settings>
        
        <pooled-connection-factory name="activemq-ra" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm" transaction="none" pre-acknowledge="true"/>
    </server>
</subsystem>

2. 仅针对目标队列配置

如果你只想让这个超时设置作用于MyJobsQueue，可以针对性配置：

<subsystem xmlns="urn:jboss:domain:messaging-activemq:4.0">
    <server name="default">
        <!-- 保留已有基础配置 -->
        <in-vm-connector name="in-vm" server-id="0"/>
        <in-vm-acceptor name="in-vm" server-id="0">
            <param name="buffer-pooling" value="false"/>
        </in-vm-acceptor>
        
        <jms-queue name="MyJobsQueue" entries="java:/jms/MyJobsQueue" />
        
        <!-- 仅针对MyJobsQueue的消费者配置超时 -->
        <consumer-settings>
            <consumer-setting match="jms.queue.MyJobsQueue">
                <consumer-idle-timeout>600000</consumer-idle-timeout>
            </consumer-setting>
        </consumer-settings>
        
        <pooled-connection-factory name="activemq-ra" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm" transaction="none" pre-acknowledge="true"/>
    </server>
</subsystem>

额外的优化建议 #

1. 修正预确认配置冲突：你的pooled-connection-factory设置了pre-acknowledge="true"，但MDB用的是Auto-acknowledge模式。预确认意味着Broker在发送消息前就标记消息为已确认，这和Auto-acknowledge的逻辑（方法执行完才确认）完全冲突，可能导致消息丢失或重发异常。建议把pre-acknowledge改为false（默认值），除非你明确需要预确认机制。

2. 改用事务模式更灵活：如果业务允许，使用JTA事务模式能更精准控制超时。修改MDB的激活配置，添加事务超时：

@MessageDriven(activationConfig = { 
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
    @ActivationConfigProperty(propertyName = "destination", propertyValue = "MyJobsQueue"),
    @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
    @ActivationConfigProperty(propertyName = "maxSession", propertyValue = "5"),
    // 设置事务超时为10分钟（单位秒）
    @ActivationConfigProperty(propertyName = "transactionTimeout", propertyValue = "600")
}) 
public class MyJobsListener implements MessageListener { 
    // 你的业务逻辑
}

同时修改连接工厂的事务属性：

<pooled-connection-factory name="activemq-ra" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm" transaction="xa" pre-acknowledge="false"/>

这种模式下，只有当MDB执行超时（超过事务超时时间）时，Broker才会重发消息，逻辑更清晰。

内容的提问来源于stack exchange，提问作者Francesco Rosso