package de.juplo.kafka.chat.backend.persistence;
-import de.juplo.kafka.chat.backend.domain.Chatroom;
+import de.juplo.kafka.chat.backend.domain.ChatRoom;
import de.juplo.kafka.chat.backend.domain.ChatHomeService;
import lombok.RequiredArgsConstructor;
@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);
+ return new ChatRoom(id, name, chatroomService, bufferSize);
}
- public Chatroom restoreChatroom(
+ public ChatRoom restoreChatroom(
UUID id,
String name,
InMemoryChatroomService chatroomService)
{
- return new Chatroom(id, name, chatroomService, bufferSize);
+ return new ChatRoom(id, name, chatroomService, bufferSize);
}
}