package de.juplo.kafka.chat.backend.persistence;
-import de.juplo.kafka.chat.backend.domain.Chatroom;
-import de.juplo.kafka.chat.backend.domain.ChatroomFactory;
+import de.juplo.kafka.chat.backend.domain.ChatRoom;
+import de.juplo.kafka.chat.backend.domain.ChatHomeService;
import lombok.RequiredArgsConstructor;
import java.util.LinkedHashMap;
@RequiredArgsConstructor
-public class InMemoryChatroomFactory implements ChatroomFactory<InMemoryChatroomService>
+public class InMemoryChatHomeService implements ChatHomeService<InMemoryChatRoomService>
{
private final int bufferSize;
@Override
- public Chatroom createChatroom(UUID id, String name)
+ public ChatRoom createChatroom(UUID id, String name)
{
- InMemoryChatroomService chatroomService =
- new InMemoryChatroomService(new LinkedHashMap<>());
- return new Chatroom(id, name, chatroomService, bufferSize);
+ InMemoryChatRoomService service =
+ new InMemoryChatRoomService(new LinkedHashMap<>());
+ return new ChatRoom(id, name, service, bufferSize);
}
- public Chatroom restoreChatroom(
+ public ChatRoom restoreChatroom(
UUID id,
String name,
- InMemoryChatroomService chatroomService)
+ InMemoryChatRoomService service)
{
- return new Chatroom(id, name, chatroomService, bufferSize);
+ return new ChatRoom(id, name, service, bufferSize);
}
}