分布式消息服务DMS如何实现死信消息的消费

标签：uri   必须   _id   是什么   提交   pos   支持   严格   无法   

GET /v1.0/{project_id}/queues/{queue_id}/groups/{consumer_group_id}/deadletters?max_msgs={max_msgs}&time_wait={time_wait}&ack_wait={ack_wait}


参数说明请参见下表：

如何确认已消费死信消息
在消费者消费死信消息期间，死信消息仍然停留在队列中，但死信消息从被消费开始的30秒内不能被该消费组再次消费，若在这30秒内没有被消费者确认消费，则DMS认为死信消息未消费成功，将可以被继续消费。


如果死信消息被确认消费成功，该死信消息将不能被该消费组再次消费，死信消息的保留时间为72小时（除非消费组被删除），72小时后会被删除。


消息批量消费确认时，必须严格按照消息消费的顺序提交确认，DMS按顺序判定消息是否消费成功，如果某条消息未确认或消费失败，则不再继续检测，默认后续消息全部消费失败。建议当对某一条消息处理失败时，不再需要继续处理本批消息中的后续消息，直接对已正确处理的消息进行确认。


注意，仅NORMAL队列和FIFO队列可以开启死信消息，因为只有NORMAL队列和FIFO队列可消费死信消息。

URI

POST /v1.0/{project_id}/queues/{queue_id}/groups/{consumer_group_id}/deadletters/ack

以上就是对分布式消息服务DMS如何实现死信消息的消费的介绍，想要了解更多，欢迎点击分布式消息服务DMS查看。

分布式消息服务DMS如何实现死信消息的消费

标签：uri   必须   _id   是什么   提交   pos   支持   严格   无法   

原文地址：http://blog.51cto.com/13739602/2137222