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:
[email protected]
