Merge pull request #517 from murDDock/fix_PullOffsetIllegal
[ISSUE #520]fix(pushConsumer):fix PullOffsetIllegal delete processQueue error
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 @@
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)
