如何从Lambda回滚消息到Amazon MQ(AMQ)?

显然,使用STOMP是不可能的,所以我将代码改为使用库ampq10。

import amqp10 from 'amqp10';

const AMQPClient = amqp10.Client;

const amqpClient = new AMQPClient({
  receiverLink: {
    attach: {
      rcvSettleMode: amqp10.Constants.receiverSettleMode.settleOnDisposition
    },
    creditQuantum: 1
  }
});

这将允许您执行 receiver.accept(message); 如果成功处理消息。如果你只是 .disconnect() 删除an .accept() 消息不会从队列中删除。