1 package de.juplo.kafka.chat.backend.persistence;
3 import de.juplo.kafka.chat.backend.domain.ChatHome;
4 import de.juplo.kafka.chat.backend.domain.ChatRoomFactory;
5 import de.juplo.kafka.chat.backend.persistence.inmemory.InMemoryChatHomeService;
6 import de.juplo.kafka.chat.backend.persistence.inmemory.InMemoryChatRoomFactory;
7 import de.juplo.kafka.chat.backend.persistence.inmemory.SimpleChatHome;
8 import lombok.RequiredArgsConstructor;
9 import lombok.extern.slf4j.Slf4j;
11 import java.time.Clock;
14 @RequiredArgsConstructor
16 public abstract class AbstractInMemoryStorageIT extends AbstractStorageStrategyIT
21 protected StorageStrategyITConfig getConfig()
23 return new StorageStrategyITConfig()
25 InMemoryChatHomeService inMemoryChatHomeService = new InMemoryChatHomeService(
28 getStorageStrategy().read());
30 SimpleChatHome simpleChatHome = new SimpleChatHome(inMemoryChatHomeService);
32 InMemoryChatRoomFactory chatRoomFactory = new InMemoryChatRoomFactory(
33 inMemoryChatHomeService,
39 public ChatHome getChatHome()
41 return simpleChatHome;
45 public ChatRoomFactory getChatRoomFactory()
47 return chatRoomFactory;