diff --git a/lib/src/main/java/io/ably/lib/transport/ConnectionManager.java b/lib/src/main/java/io/ably/lib/transport/ConnectionManager.java
index 004c7d211..8e421bc8f 100644
--- 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);
+            }
         }
     }