-package de.juplo.kafka.chat.backend.persistence;
+package de.juplo.kafka.chat.backend.persistence.inmemory;
import de.juplo.kafka.chat.backend.domain.Message;
import de.juplo.kafka.chat.backend.domain.ChatRoomService;
private final LinkedHashMap<Message.MessageKey, Message> messages;
- public InMemoryChatRoomService(LinkedHashMap<Message.MessageKey, Message> messages)
- {
- this.messages = messages;
- }
-
public InMemoryChatRoomService(Flux<Message> messageFlux)
{
log.debug("Creating InMemoryChatRoomService");