Remove unused import

Reassign message serials on pending message queue
ably · Jan 18, 2023 · 34a6826 · 34a6826
1 parent 41ca405
commit 34a6826
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/lib/src/main/java/io/ably/lib/transport/ConnectionManager.java b/lib/src/main/java/io/ably/lib/transport/ConnectionManager.java
@@ -1742,6 +1742,11 @@ public synchronized void reset(long oldMsgSerial, ErrorInfo err) {
 
         public void resetStartSerial(int from) {
              startSerial = from;
+            //also reassign new serials to queued messages
+            for (int i = 0; i < queuedMessages.size(); i++) {
+                final QueuedMessage queuedMessage = queuedMessages.get(i);
+                queuedMessage.msg.msgSerial = (long) (i + from);
+            }
         }
     }