refactor: Renamed `ChatRoom` into `ChatRoomData` - Aligned Code
authorKai Moritz <kai@juplo.de>
Mon, 4 Sep 2023 21:13:59 +0000 (23:13 +0200)
committerKai Moritz <kai@juplo.de>
Mon, 4 Sep 2023 21:13:59 +0000 (23:13 +0200)
src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHome.java

index c6f3377..fb6c184 100644 (file)
@@ -87,6 +87,7 @@ public class SimpleChatHome implements ChatHome
     log.info("Creating ChatRoom with buffer-size {}", bufferSize);
     ChatRoomService service = new InMemoryChatRoomService(Flux.empty());
     ChatRoomInfo chatRoomInfo = new ChatRoomInfo(id, name, shard);
+    this.chatRoomInfo.put(id, chatRoomInfo);
     ChatRoomData chatRoomData = new ChatRoomData(clock, service, bufferSize);
     this.chatRoomData.put(id, chatRoomData);
     return Mono.just(chatRoomInfo);