Merge pull request #517 from murDDock/fix_PullOffsetIllegal

[ISSUE #520]fix(pushConsumer):fix PullOffsetIllegal delete processQueue error
apache · Sep 6, 2020 · 0d7212c · 0d7212c
2 parents f9b98f4 + 0ab79c0
commit 0d7212c
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)