我已经配置了SQS监听器以消耗消息列表,但我一次只收到一条消息,并且出现了错误:“无法将model.StudentData转换为java.util.ArrayList的实例”。
我的代码如下:
任何关于如何配置 SQS 监听器以消费多个消息的建议都会受到赞赏。
感谢您的帮助。
我的代码如下:
@SqsListener(value = "${queueName}", deletionPolicy = SqsMessageDeletionPolicy.NEVER)
public void receiveMessage(final StudentData studentData,
@Header("SenderId") final String senderId, final Acknowledgment acknowledgment) {
// business logic
acknowledgment.acknowledge();
}
任何关于如何配置 SQS 监听器以消费多个消息的建议都会受到赞赏。
感谢您的帮助。
setMaxNumberOfMessages
只允许设置1到10之间的值。因此,这段代码很可能无法按预期工作。还请查看 JavaDoc 类ReceiveMessageRequest
。 - Oliver Marienfeld