diff --git a/packages/stream_chat/lib/src/api/channel.dart b/packages/stream_chat/lib/src/api/channel.dart
index 1f5da466..38f990b0 100644
--- a/packages/stream_chat/lib/src/api/channel.dart
+++ b/packages/stream_chat/lib/src/api/channel.dart
@@ -1441,7 +1441,7 @@ class ChannelClientState {
 
       final oldIndex = newMessages.indexWhere((m) => m.id == message.id);
       if (oldIndex != -1) {
-        newMessages[oldIndex] = newMessages[oldIndex].merge(message);
+        newMessages[oldIndex] = message;
       } else {
         newMessages.add(message);
       }
diff --git a/packages/stream_chat/lib/src/api/retry_queue.dart b/packages/stream_chat/lib/src/api/retry_queue.dart
index de3ca610..34046545 100644
--- a/packages/stream_chat/lib/src/api/retry_queue.dart
+++ b/packages/stream_chat/lib/src/api/retry_queue.dart
@@ -47,6 +47,7 @@ class RetryQueue {
 
   /// Add a list of messages
   void add(List<Message> messages) {
+    logger?.info('added ${messages.length} messages');
     final messageList = _messageQueue.toList();
     _messageQueue.addAll(messages
         .where((element) => !messageList.any((m) => m.id == element.id)));