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.InMemoryWithMongoDbStorageIT.DataSourceInitializer;
-import de.juplo.kafka.chat.backend.persistence.inmemory.InMemoryChatRoomFactory;
import de.juplo.kafka.chat.backend.persistence.inmemory.InMemoryChatRoomService;
import de.juplo.kafka.chat.backend.persistence.storage.mongodb.ChatRoomRepository;
import de.juplo.kafka.chat.backend.persistence.storage.mongodb.MongoDbStorageStrategy;
@AutoConfigureDataMongo
@ContextConfiguration(initializers = DataSourceInitializer.class)
@Slf4j
-public class InMemoryWithMongoDbStorageIT extends AbstractStorageStrategyIT
+public class InMemoryWithMongoDbStorageIT extends AbstractInMemoryStorageIT
{
@Autowired
MongoDbStorageStrategy storageStrategy;
Clock clock;
- @Override
- protected StorageStrategy getStorageStrategy()
+ public InMemoryWithMongoDbStorageIT()
{
- return storageStrategy;
+ super(Clock.systemDefaultZone());
}
+
@Override
- protected StorageStrategyITConfig getConfig()
+ protected StorageStrategy getStorageStrategy()
{
- return new StorageStrategyITConfig()
- {
- InMemoryChatHomeService chatHomeService = new InMemoryChatHomeService(
- 1,
- new int[] { 0 },
- getStorageStrategy().read());
-
- InMemoryChatRoomFactory chatRoomFactory = new InMemoryChatRoomFactory(
- chatRoomId -> 0,
- clock,
- 8);
-
- @Override
- public ChatHomeService getChatHomeService()
- {
- return chatHomeService;
- }
-
- @Override
- public ChatRoomFactory getChatRoomFactory()
- {
- return chatRoomFactory;
- }
- };
+ return storageStrategy;
}
@TestConfiguration