你提到的问题是关于处理异步未确认消息的方式,以及在处理批量消息时的疑问。
首先,确保理解了headMap()方法的作用。headMap(deliveryTag)返回的是一个视图,其中包含键值小于deliveryTag的所有条目。这意味着outstadingConfirms.headMap(deliveryTag)实际上返回了小于等于deliveryTag的所有条目。因此,在处理确认成功的消息时,应该使用`outstadingConfirms.headMap(delivery...
headMap()
headMap(deliveryTag)
deliveryTag
outstadingConfirms.headMap(deliveryTag)
你提到的问题是关于处理异步未确认消息的方式,以及在处理批量消息时的疑问。
首先,确保理解了
headMap()方法的作用。headMap(deliveryTag)返回的是一个视图,其中包含键值小于deliveryTag的所有条目。这意味着outstadingConfirms.headMap(deliveryTag)实际上返回了小于等于deliveryTag的所有条目。因此,在处理确认成功的消息时,应该使用`outstadingConfirms.headMap(delivery...