You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2021/01/07 09:53:44 UTC
[rocketmq-client-go] branch master updated: [ISSUE #583] fix
printlog crash
This is an automated email from the ASF dual-hosted git repository.
dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 3af02f1 [ISSUE #583] fix printlog crash
3af02f1 is described below
commit 3af02f1bcb530cb21188cd05a7ea072d3fdf77c5
Author: NAND86 <32...@users.noreply.github.com>
AuthorDate: Thu Jan 7 17:53:33 2021 +0800
[ISSUE #583] fix printlog crash
fix #583 pullMessage & printlog crash
---
consumer/push_consumer.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index 931fefa..5177fd9 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -516,7 +516,7 @@ func (pc *pushConsumer) pullMessage(request *PullRequest) {
"PullThresholdForQueue": pc.option.PullThresholdForQueue,
"minOffset": pq.Min(),
"maxOffset": pq.Max(),
- "count": pq.msgCache,
+ "count": pq.cachedMsgCount,
"size(MiB)": cachedMessageSizeInMiB,
"flowControlTimes": pc.queueFlowControlTimes,
rlog.LogKeyPullRequest: request.String(),
@@ -533,7 +533,7 @@ func (pc *pushConsumer) pullMessage(request *PullRequest) {
"PullThresholdSizeForQueue": pc.option.PullThresholdSizeForQueue,
"minOffset": pq.Min(),
"maxOffset": pq.Max(),
- "count": pq.msgCache,
+ "count": pq.cachedMsgCount,
"size(MiB)": cachedMessageSizeInMiB,
"flowControlTimes": pc.queueFlowControlTimes,
rlog.LogKeyPullRequest: request.String(),