IBM MQ + Mule 4：DLQ消息仅重处理一次的过滤方案求助

一、先搞定选择器报错的问题 #

你之前用attributes.headers.redelivery=false报错，是因为IBM MQ的消息选择器不支持这种嵌套写法，得用MQ原生的消息属性或者自定义属性来做判断，不能瞎写路径。

二、核心思路：给消息打「已重试」标记 #

要避免无限循环，核心就是给DLQ里的消息加个标记——没处理过的不带标记或者标记为未重试，处理过的改成已重试。消费DLQ时只挑没被标记过的消息，处理完不管成功失败都打上标记，这样就不会重复处理了。

三、具体操作步骤 #

1. 给DLQ消息加自定义标记 #

当消息第一次进入DLQ时，在消息的自定义属性或者MQRFH2头里加个标记，比如叫IsRetried：

• 首次进DLQ的消息，设IsRetried=false或者干脆不设（默认null）；
• 重处理过的消息，把这个属性改成IsRetried=true。

2. 正确的选择器写法 #

IBM MQ的选择器遵循JMS规范，直接引用属性就行：

• 如果用自定义属性IsRetried，选择器写：IsRetried IS NULL OR IsRetried = false
• 如果是存在MQRFH2头里的用户属性，得用映射后的JMS属性名，比如JMS_IBM_MQRFH2_usr_IsRetried = false

3. 重处理代码示例（Java） #

// 创建DLQ消费者，带上选择器
String selector = "IsRetried IS NULL OR IsRetried = false";
MessageConsumer dlqConsumer = session.createConsumer(dlqQueue, selector);

Message message = dlqConsumer.receive();
if (message != null) {
    try {
        // 执行你的消息处理逻辑
        processBusinessLogic(message);
        
        // 处理成功，确认消息，不用再管了
        session.commit();
    } catch (Exception e) {
        // 处理失败，给消息打上已重试标记，再送回DLQ
        message.setBooleanProperty("IsRetried", true);
        MessageProducer dlqProducer = session.createProducer(dlqQueue);
        dlqProducer.send(message);
        // 确认原消息，防止重复消费
        session.commit();
    }
}

4. 额外防循环保障 #

• 加重试次数上限：可以再加个RetryCount属性，每次重处理就+1，到1次就直接转到永久归档队列，彻底杜绝循环；
• 用专门的重处理队列：别直接在DLQ上操作，先把符合条件的消息移到重处理队列，处理完要么归档要么走正常流程，避免DLQ消息混乱。

四、遗留问题处理 #

如果之前的DLQ消息都没加自定义属性，先写个批量脚本，给所有没标记的消息加上IsRetried=false，再启动重处理消费就行。另外如果DLQ消息量特别大，选择器可能影响性能，建议配合MQ的队列分区或者定期清理策略。

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