如何测试发送到SQS队列的JMS消息是否进入死信队列

我正在为处理SQS队列消息的MessageListener编写集成测试，其中一个核心测试用例需要验证：发送给MessageListener的格式不正确的消息，是否会被转入在AWS控制台配置的死信队列（DLQ，本质也是SQS队列）。

但测试过程中遇到了几个棘手问题：

• 无法通过特定消息ID直接搜索死信队列，只能遍历所有消息来判断目标消息是否存在。但测试环境的DLQ中已有未知数量的历史消息，且还会持续新增，这种遍历方式完全不可行。
• 尝试过利用JMS消息的相关属性来追踪消息，但消息从测试端发送到SQS队列，再流转到MessageListener的过程中，本地实例的消息属性不会同步更新，没法通过属性关联目标消息。
• 格式正确的消息可以通过验证数据库修改记录来确认处理结果，但格式错误的消息不会触发任何数据库交互，这条验证路径无效。
• 额外限制：Amazon SQS的JMS客户端实现不支持消息选择器，没法通过选择器过滤目标消息。

示例代码 #

MessageListener实现 #

public class ExampleMessageListener implements MessageListener {

    @Override
    public void onMessage(final Message message) {
        // 消息处理逻辑
        
        // 如果消息处理逻辑出错，消息不会被确认，最终应该进入DLQ
        message.acknowledge();
    }
}

集成测试中发送消息的代码 #

SQSConnectionFactory connectionFactory = new SQSConnectionFactory(
    new ProviderConfiguration(),
    AmazonSQSClientBuilder.standard()
                          .withRegion(config.getRegion().getName())
                          .withCredentials(config.getCredentialsProvider())
);
        
SQSConnection connection = connectionFactory.createConnection();
session = connection.createSession(false, SQSSession.UNORDERED_ACKNOWLEDGE);
final Queue queue = session.createQueue("SQS-queue-name");
this.messageProducer = session.createProducer(queue);
final TextMessage textMessage = session.createTextMessage("improper message");
messageProducer.send(textMessage);

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