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 8e3cc4305b3df480059eb4d934996f8c36f4bd7e..e78b049b07cbf15ef7b48ab3c2fcd8ffefd56385 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))