X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2FInMemoryWithMongoDbStorageIT.java;h=7566f521e05332dae826f8038e7e049549868892;hb=8e3e1cb5ca959f6ac096a2ec7d1a2c6a235cf32d;hp=43a09003baf164f3c66caa574768ce962e7a2e65;hpb=386f950f8b329bf2b956fa7896e270a39037967d;p=demos%2Fkafka%2Fchat diff --git a/src/test/java/de/juplo/kafka/chat/backend/InMemoryWithMongoDbStorageIT.java b/src/test/java/de/juplo/kafka/chat/backend/InMemoryWithMongoDbStorageIT.java index 43a09003..7566f521 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/InMemoryWithMongoDbStorageIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/InMemoryWithMongoDbStorageIT.java @@ -60,13 +60,9 @@ public class InMemoryWithMongoDbStorageIT extends AbstractInMemoryStorageIT @Bean MongoDbStorageStrategy storageStrategy( ChatRoomRepository chatRoomRepository, - MessageRepository messageRepository, - Clock clock) + MessageRepository messageRepository) { - return new MongoDbStorageStrategy( - chatRoomRepository, - messageRepository, - chatRoomId -> 0); + return new MongoDbStorageStrategy(chatRoomRepository, messageRepository); } @Bean @@ -80,8 +76,7 @@ public class InMemoryWithMongoDbStorageIT extends AbstractInMemoryStorageIT @Container private static final GenericContainer CONTAINER = - new GenericContainer("mongo:6") - .withExposedPorts(MONGODB_PORT); + new GenericContainer("mongo:6").withExposedPorts(MONGODB_PORT); public static class DataSourceInitializer implements ApplicationContextInitializer