import de.juplo.kafka.chat.backend.domain.ChatHomeService;
import lombok.RequiredArgsConstructor;
+import java.time.Clock;
import java.util.LinkedHashMap;
import java.util.UUID;
@RequiredArgsConstructor
-public class InMemoryChatHomeService implements ChatHomeService<InMemoryChatroomService>
+public class InMemoryChatHomeService implements ChatHomeService<InMemoryChatRoomService>
{
+ private final Clock clock;
private final int bufferSize;
@Override
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, clock, service, bufferSize);
}
public ChatRoom restoreChatroom(
UUID id,
String name,
- InMemoryChatroomService chatroomService)
+ InMemoryChatRoomService service)
{
- return new ChatRoom(id, name, chatroomService, bufferSize);
+ return new ChatRoom(id, name, clock, service, bufferSize);
}
}