1 package de.juplo.kafka.chat.backend.persistence;
3 import de.juplo.kafka.chat.backend.domain.Chatroom;
4 import de.juplo.kafka.chat.backend.domain.ChatroomFactory;
5 import de.juplo.kafka.chat.backend.domain.PersistenceStrategy;
6 import lombok.RequiredArgsConstructor;
7 import org.springframework.stereotype.Component;
12 @RequiredArgsConstructor
13 public class InMemoryChatroomFactory implements ChatroomFactory
15 private final PersistenceStrategy persistenceStrategy;
19 public Chatroom createChatroom(UUID id, String name)
21 return new Chatroom(id, name, persistenceStrategy);