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