From 6570d71234fc6f47debee27ffa0d2d1076a8dc0f Mon Sep 17 00:00:00 2001
From: imndx <imndxx@gmail.com>
Date: Wed, 8 May 2019 21:20:34 +0800
Subject: [PATCH] user pull seq

---
 .../main/java/io/moquette/persistence/MemoryMessagesStore.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
index d26046d8..d4740624 100755
--- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
@@ -455,7 +455,7 @@ public class MemoryMessagesStore implements IMessagesStore {
             if (lastEntry != null) {
                 messageSeq = (lastEntry.getKey() + 1);
             }
-            Long maxPullSeq = userMaxPullSeq.get(sender);
+            Long maxPullSeq = userMaxPullSeq.get(user);
             if (maxPullSeq != null && maxPullSeq > messageSeq) {
                 messageSeq = maxPullSeq + 1;
             }