package de.juplo.kafka.chat.backend.persistence;
import de.juplo.kafka.chat.backend.persistence.InMemoryWithMongoDbStorageIT.DataSourceInitializer;
-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.MessageRepository;
import de.juplo.kafka.chat.backend.persistence.storage.mongodb.MongoDbStorageStrategy;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.BeforeEach;
@Autowired
MongoDbStorageStrategy storageStrategy;
@Autowired
- ChatRoomRepository repository;
+ ChatRoomRepository chatRoomRepository;
@Autowired
- Clock clock;
+ MessageRepository messageRepository;
public InMemoryWithMongoDbStorageIT()
@Bean
MongoDbStorageStrategy storageStrategy(
ChatRoomRepository chatRoomRepository,
+ MessageRepository messageRepository,
Clock clock)
{
return new MongoDbStorageStrategy(
chatRoomRepository,
- clock,
- 8,
- chatRoomId -> 0,
- messageFlux -> new InMemoryChatRoomService(messageFlux));
+ messageRepository,
+ chatRoomId -> 0);
}
@Bean
{
Slf4jLogConsumer logConsumer = new Slf4jLogConsumer(log);
CONTAINER.followOutput(logConsumer);
- repository.deleteAll();
+ chatRoomRepository.deleteAll();
+ messageRepository.deleteAll();
}
}