[rocketmq-client-go] branch master updated: [ISSUE #956]fix reset offset remove pq (#957)

[maixiaohai]

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

maixiaohai 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 6bbfc3f  [ISSUE #956]fix reset offset remove pq (#957)
6bbfc3f is described below

commit 6bbfc3f50f895de8823901142fea60add35b94ea
Author: 0daypwn <30897509+0day...@users.noreply.github.com>
AuthorDate: Thu Nov 3 21:08:24 2022 +0800

    [ISSUE #956]fix reset offset remove pq (#957)
---
 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 da7ba92..e91bad0 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -965,7 +965,7 @@ func (pc *pushConsumer) ResetOffset(topic string, table 
map[primitive.MessageQue
                        }
                        pq := v.(*processQueue)
                        pc.removeUnnecessaryMessageQueue(mq, pq)
-                       pc.processQueueTable.Delete(mq)
+                       pc.processQueueTable.Delete(*mq)
                }
        }
 }