[GitHub] [rocketmq-client-go] qianlongzt commented on issue #650: Orderly Consumer will not reconsume the message

[GitBox <gi...@apache.org>]

qianlongzt commented on issue #650:
URL: https://github.com/apache/rocketmq-client-go/issues/650#issuecomment-832581056


   ```go
   type processQueue struct {
   	cachedMsgCount             int64
   	cachedMsgSize              int64
   
   	msgCache                   *treemap.Map
   	consumingMsgOrderlyTreeMap *treemap.Map
   }
   ```
   i think `cachedMsgCount`  mean pulled msgCount ,now  equal `msgCache.Size() + consumingMsgOrderlyTreeMap.Size()`, used by https://github.com/apache/rocketmq-client-go/blob/dfa26d159f9f47cf38c8788dc3ae9443bad61e0d/consumer/push_consumer.go#L583 
   
   first problem is #615 ,if consuming orderly and failed, the cachedMsgCount  will increase and can't consume any more.
   I send a pr to fix #616 ,but got another problem( #618   msg lost when failed).
   so pr #619 make cachedMsgCount and msg both ok
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org