refactor: A `ChatRoom` does not have to remember its shard any more
[demos/kafka/chat] / src / test / java / de / juplo / kafka / chat / backend / persistence / InMemoryWithMongoDbStorageIT.java
index 9808aa3..ecc64d5 100644 (file)
@@ -55,6 +55,7 @@ public class InMemoryWithMongoDbStorageIT extends AbstractStorageStrategyIT
   protected Supplier<ChatHomeService> getChatHomeServiceSupplier()
   {
     return () -> new InMemoryChatHomeService(
+        chatRoomId -> 0,
         1,
         new int[] { 0 },
         getStorageStrategy().read());
@@ -79,7 +80,6 @@ public class InMemoryWithMongoDbStorageIT extends AbstractStorageStrategyIT
           chatRoomRepository,
           clock,
           8,
-          chatRoomId -> 0,
           messageFlux -> new InMemoryChatRoomService(messageFlux));
     }