diff --git a/app/src/main/java/org/thoughtcrime/securesms/database/Storage.kt b/app/src/main/java/org/thoughtcrime/securesms/database/Storage.kt
index 69486e5520..51278b70d5 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/database/Storage.kt
+++ b/app/src/main/java/org/thoughtcrime/securesms/database/Storage.kt
@@ -496,6 +496,8 @@ open class Storage(context: Context, helper: SQLCipherOpenHelper, private val co
 
     private fun updateConvoVolatile(convos: ConversationVolatileConfig) {
         val extracted = convos.all()
+        Log.d("Loki-DBG", "All conversations")
+        Log.d("Loki-DBG", convos.allCommunities().joinToString("\n"))
         for (conversation in extracted) {
             val threadId = when (conversation) {
                 is Conversation.OneToOne -> getThreadIdFor(conversation.sessionId, null, null, createThread = false)
@@ -1046,6 +1048,7 @@ open class Storage(context: Context, helper: SQLCipherOpenHelper, private val co
             markConversationAsRead(threadId, volatile.lastRead, force = true)
             Log.d("Loki-DBG", "set latest volatile read for $room to ${volatile.lastRead}")
         }
+        volatileConfig.set(volatile)
     }
 
     override fun hasBackgroundGroupAddJob(groupJoinUrl: String): Boolean {
diff --git a/libsession/src/main/java/org/session/libsession/messaging/jobs/BatchMessageReceiveJob.kt b/libsession/src/main/java/org/session/libsession/messaging/jobs/BatchMessageReceiveJob.kt
index 4019f81daa..d1d5989df4 100644
--- a/libsession/src/main/java/org/session/libsession/messaging/jobs/BatchMessageReceiveJob.kt
+++ b/libsession/src/main/java/org/session/libsession/messaging/jobs/BatchMessageReceiveJob.kt
@@ -229,7 +229,7 @@ class BatchMessageReceiveJob(
                     if (!openGroupID.isNullOrEmpty()) {
                         Log.d("Loki-DBG", "new-lastSeen for: $openGroupID is $currentLastSeen")
                     }
-                    storage.markConversationAsRead(threadId, newLastSeen)
+                    storage.markConversationAsRead(threadId, newLastSeen, force = true)
                     storage.updateThread(threadId, true)
                     SSKEnvironment.shared.notificationManager.updateNotification(context, threadId)
                 }