解决关闭roaming,且message.compensate_time_limit配置为-1时,首次消息无法同步的问题
This commit is contained in:
@@ -847,6 +847,10 @@ public class MemoryMessagesStore implements IMessagesStore {
|
|||||||
mReadLock.unlock();
|
mReadLock.unlock();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if(current == 0) {
|
||||||
|
current = 2;
|
||||||
|
head = 2;
|
||||||
|
}
|
||||||
builder.setCurrent(current);
|
builder.setCurrent(current);
|
||||||
builder.setHead(head);
|
builder.setHead(head);
|
||||||
return builder.build();
|
return builder.build();
|
||||||
@@ -1000,7 +1004,7 @@ public class MemoryMessagesStore implements IMessagesStore {
|
|||||||
messageSeq = maxPullSeq + 1;
|
messageSeq = maxPullSeq + 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (messageSeq == 0) {
|
if (messageSeq < messageId) {
|
||||||
messageSeq = messageId;
|
messageSeq = messageId;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user