1 package de.juplo.kafka.chat.backend.persistence.inmemory;
3 import de.juplo.kafka.chat.backend.domain.ChatHome;
4 import de.juplo.kafka.chat.backend.domain.ChatHomeFactory;
5 import lombok.RequiredArgsConstructor;
8 @RequiredArgsConstructor
9 public class InMemoryChatHomeFactory implements ChatHomeFactory
11 private final InMemoryChatHomeService service;
15 public ChatHome createChatHome(int shard)
17 return new ChatHome(service, shard);