package de.juplo.kafka.chat.backend.persistence;
-import de.juplo.kafka.chat.backend.persistence.inmemory.ChatHomeService;
+import de.juplo.kafka.chat.backend.domain.ChatHome;
import de.juplo.kafka.chat.backend.domain.ChatRoomFactory;
import de.juplo.kafka.chat.backend.persistence.inmemory.InMemoryChatHomeService;
import de.juplo.kafka.chat.backend.persistence.inmemory.InMemoryChatRoomFactory;
+import de.juplo.kafka.chat.backend.persistence.inmemory.SimpleChatHome;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
{
return new StorageStrategyITConfig()
{
- InMemoryChatHomeService chatHomeService = new InMemoryChatHomeService(
+ InMemoryChatHomeService inMemoryChatHomeService = new InMemoryChatHomeService(
1,
new int[] { 0 },
getStorageStrategy().read());
+ SimpleChatHome simpleChatHome = new SimpleChatHome(inMemoryChatHomeService);
+
InMemoryChatRoomFactory chatRoomFactory = new InMemoryChatRoomFactory(
- chatHomeService,
+ inMemoryChatHomeService,
chatRoomId -> 0,
clock,
8);
@Override
- public ChatHomeService getChatHomeService()
+ public ChatHome getChatHome()
{
- return chatHomeService;
+ return simpleChatHome;
}
@Override