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>
{
+ private final Clock clock;
private final int bufferSize;
{
InMemoryChatRoomService service =
new InMemoryChatRoomService(new LinkedHashMap<>());
- return new ChatRoom(id, name, service, bufferSize);
+ return new ChatRoom(id, name, clock, service, bufferSize);
}
public ChatRoom restoreChatroom(
String name,
InMemoryChatRoomService service)
{
- return new ChatRoom(id, name, service, bufferSize);
+ return new ChatRoom(id, name, clock, service, bufferSize);
}
}