[rocketmq-client-go] branch master updated: fix(pushConsumer):fix PullOffsetIllegal delete processQueue error

[jianhaixu]

This is an automated email from the ASF dual-hosted git repository.

jianhaixu 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 0ab79c0  fix(pushConsumer):fix PullOffsetIllegal delete processQueue 
error
     new 0d7212c  Merge pull request #517 from murDDock/fix_PullOffsetIllegal
0ab79c0 is described below

commit 0ab79c09371e9d48796ea9183cfc214d4d0e74c5
Author: huangxingning <huangxingn...@bytedance.com>
AuthorDate: Thu Jul 30 10:57:22 2020 +0800

    fix(pushConsumer):fix PullOffsetIllegal delete processQueue error
    
    Change-Id: Iba9a65d5e0bfdc513ee65e0f121b8cc2b4a76ad1
---
 consumer/push_consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index 25b8ce8..58945c2 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -705,7 +705,7 @@ func (pc *pushConsumer) pullMessage(request *PullRequest) {
                        time.Sleep(10 * time.Second)
                        pc.storage.update(request.mq, request.nextOffset, false)
                        
pc.storage.persist([]*primitive.MessageQueue{request.mq})
-                       pc.processQueueTable.Delete(request.mq)
+                       pc.processQueueTable.Delete(*request.mq)
                        rlog.Warning(fmt.Sprintf("fix the pull request offset: 
%s", request.String()), nil)
                default:
                        rlog.Warning(fmt.Sprintf("unknown pull status: %v", 
result.Status), nil)