fix pull message issue

2019-12-10 23:34:15 +08:00
parent beb403a9f7
commit b6be1ca045
1 changed files with 5 additions and 2 deletions
@@ -353,6 +353,9 @@ public class MemoryMessagesStore implements IMessagesStore {

                        size += bundle.getMessage().getSerializedSize();
                        if (size >= 512 * 1024) { //3M
+                            if(builder.getMessageCount() == 0){
+                                builder.addMessage(bundle.getMessage());
+                            }
                            break;
                        }
                        builder.addMessage(bundle.getMessage());
@@ -1996,7 +1999,7 @@ public class MemoryMessagesStore implements IMessagesStore {
        } else {
            state = 0;
        }
-        
+
        HazelcastInstance hzInstance = m_Server.getHazelcastInstance();
        MultiMap<String, FriendData> friendsMap = hzInstance.getMultiMap(USER_FRIENDS);

@@ -2642,7 +2645,7 @@ public class MemoryMessagesStore implements IMessagesStore {
        }
        return UUIDGenerator.getUUID();
    }
-    
+
    @Override
    public void storeRetained(Topic topic, StoredMessage storedMessage) {
        LOG.debug("Store retained message for topic={}, CId={}", topic, storedMessage.getClientID());