手动 ACK 批量 AMQP 消息

问题描述

我可以使用以下代码接收批处理消息。但现在我的问题是,我应该如何手动确认消息。一一ACK列表中的所有消息,还是ACK列表中的最后一条消息就够了?提前致谢!


public class MyMessageListener implements ChannelAwareBatchMessageListener {

@Override
public void onMessageBatch(List<Message> messages,Channel channel){

//Do something......
    
//option 1    
 messages.forEach(msg-> channel.basicAck(msg.getMessageProperties().getDeliveryTag(),true); 

//option 2
channel.basicAck( messages.get(messages.size()-1).getMessageProperties().getDeliveryTag(),true);
        
   }

}

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)