@Autowired
MongoDbStorageStrategy storageStrategy;
@Autowired
+ ChatRoomRepository repository;
+ @Autowired
Clock clock;
protected Supplier<ChatHomeService> getChatHomeServiceSupplier()
{
return () -> new InMemoryChatHomeService(
- chatRoomId -> 0,
1,
new int[] { 0 },
getStorageStrategy().read());
chatRoomRepository,
clock,
8,
+ chatRoomId -> 0,
messageFlux -> new InMemoryChatRoomService(messageFlux));
}
{
Slf4jLogConsumer logConsumer = new Slf4jLogConsumer(log);
CONTAINER.followOutput(logConsumer);
+ repository.deleteAll();
}
}