如何配置WSO2 ESB消息处理器将失败消息转至死信队列(DLQ)？

一、修正WSO2 MI消息处理器核心配置 #

确保消息处理器配置包含以下关键参数，缺失项会导致DLQ转发失效：

• maxRetryCount：设置消息最大重试次数（示例值：5）
• retryInterval：重试间隔（示例值：1000，单位毫秒）
• deadLetterQueue：指定ActiveMQ中的DLQ队列名称（可使用默认ActiveMQ.DLQ或自定义队列名）
• disableOnFailure：必须设为false，否则达到重试次数后处理器会直接停用，而非转发消息到DLQ

示例配置片段：

<messageProcessor name="JMSConsumerProcessor" class="org.apache.synapse.message.processors.forwarder.ScheduledMessageForwardingProcessor" targetEndpoint="YourTargetEndpoint">
    <parameter name="interval">1000</parameter>
    <parameter name="max.delivery.attempts">5</parameter>
    <parameter name="maxRetryCount">5</parameter>
    <parameter name="retryInterval">1000</parameter>
    <parameter name="deadLetterQueue">ActiveMQ.DLQ</parameter>
    <parameter name="disableOnFailure">false</parameter>
    <parameter name="transport.jms.ConnectionFactoryJNDIName">QueueConnectionFactory</parameter>
    <parameter name="java.naming.factory.initial">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
    <parameter name="java.naming.provider.url">tcp://localhost:61616</parameter>
    <parameter name="transport.jms.DestinationType">queue</parameter>
    <parameter name="transport.jms.Destination">inputQueue</parameter>
</messageProcessor>

二、配置ActiveMQ Classic的死信转发策略 #

若WSO2 MI内置重试机制未触发DLQ转发，需在ActiveMQ的activemq.xml中配置死信策略：

1. 找到policyEntries节点，添加目标队列的专属策略：

<policyEntries>
    <policyEntry queue="inputQueue">
        <deadLetterStrategy>
            <individualDeadLetterStrategy queuePrefix="DLQ." useQueueForQueueMessages="true" />
        </deadLetterStrategy>
    </policyEntry>
</policyEntries>

• queuePrefix：自定义DLQ前缀，配置后inputQueue的死信会自动路由到DLQ.inputQueue

2. 若使用全局共享DLQ，可配置：

<deadLetterStrategy>
    <sharedDeadLetterStrategy deadLetterQueue="ActiveMQ.DLQ" processNonPersistent="true" processPersistent="true" />
</deadLetterStrategy>

三、关键注意事项 #

• 确保WSO2 MI的JMS传输配置可正常连接ActiveMQ，且拥有DLQ队列的读写权限
• 查看WSO2 MI日志（repository/logs/wso2carbon.log），搜索Dead letter queue关键字，确认消息转发日志
• 自定义DLQ需提前在ActiveMQ中创建，或开启ActiveMQ自动创建队列的配置

四、验证DLQ功能 #

1. 发送一条无法被目标端点处理的测试消息到输入队列
2. 等待达到maxRetryCount次数后，通过ActiveMQ控制台（默认http://localhost:8161）检查DLQ队列，确认消息已转移
3. 确认消息处理器未被停用，仍在正常运行

内容的提问来源于stack exchange，提问作者Some Guy