1 package de.juplo.kafka.chat.backend.persistence;
3 import de.juplo.kafka.chat.backend.domain.ChatRoom;
4 import de.juplo.kafka.chat.backend.domain.ChatHomeService;
5 import lombok.RequiredArgsConstructor;
7 import java.util.LinkedHashMap;
11 @RequiredArgsConstructor
12 public class InMemoryChatHomeService implements ChatHomeService<InMemoryChatroomService>
14 private final int bufferSize;
18 public ChatRoom createChatroom(UUID id, String name)
20 InMemoryChatroomService chatroomService =
21 new InMemoryChatroomService(new LinkedHashMap<>());
22 return new ChatRoom(id, name, chatroomService, bufferSize);
25 public ChatRoom restoreChatroom(
28 InMemoryChatroomService chatroomService)
30 return new ChatRoom(id, name, chatroomService, bufferSize);