Stalehelp wantedlifecycle/staletype/bug
仓库指标
- Star
- (13,697 star)
- PR 合并指标
- (平均合并 3天 10小时) (30 天内合并 146 个 PR)
描述
Describe the bug PoolMessage and DLQ can not work together
To Reproduce Steps to reproduce the behavior:
- Enable poolMessages and DLQ in consumer side
- Call
consumer.negativeAcknowledge(message)and then callmessage.release() - The message did not resend to DLQ topic.
Expected behavior The message should be sent to DLQ topic.
Additional context
The negative ack msgs will be sent to DLQ topic in a scheduler triggerRedelivery, when we enable poolMessages, message.release() will clear MessageImpl immediately, this will cause processPossibleToDLQ() fail to get message id and resend to DLQ.