fix(pushConsumer):fix PullOffsetIllegal delete processQueue error

Change-Id: Iba9a65d5e0bfdc513ee65e0f121b8cc2b4a76ad1
apache · Jul 30, 2020 · 0ab79c0 · 0ab79c0
1 parent 80b3acc
commit 0ab79c0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)