1 package de.juplo.kafka.chat.backend.persistence;
3 import de.juplo.kafka.chat.backend.domain.ChatHomeService;
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 lombok.RequiredArgsConstructor;
8 import lombok.extern.slf4j.Slf4j;
10 import java.time.Clock;
13 @RequiredArgsConstructor
15 public abstract class AbstractInMemoryStorageIT extends AbstractStorageStrategyIT
20 protected StorageStrategyITConfig getConfig()
22 return new StorageStrategyITConfig()
24 InMemoryChatHomeService chatHomeService = new InMemoryChatHomeService(
27 getStorageStrategy().read());
29 InMemoryChatRoomFactory chatRoomFactory = new InMemoryChatRoomFactory(
35 public ChatHomeService getChatHomeService()
37 return chatHomeService;
41 public ChatRoomFactory getChatRoomFactory()
43 return chatRoomFactory;