fix: `ChatRoomData` must only be activated after restoring completes

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/inmemory/SimpleChatHomeService.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/inmemory/SimpleChatHomeService.java
index 8e3cc43..e78b049 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/inmemory/SimpleChatHomeService.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/inmemory/SimpleChatHomeService.java
@@ -81,10 +81,11 @@ public class SimpleChatHomeService implements ChatHomeService
                   clock,
                   chatMessageService,
                   historyLimit);
-          chatRoomData.activate();
           this.chatRoomData.put(info.getId(), chatRoomData);
 
-          return chatMessageService.restore(storageStrategy);
+          return chatMessageService
+              .restore(storageStrategy)
+              .doOnSuccess(noResult -> chatRoomData.activate());
         })
         .count()
         .doOnSuccess(count -> log.info("Restored {} with {} chat-rooms", this, count))