X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fpersistence%2Finmemory%2FSimpleChatHomeTest.java;h=8be31731dca6b59a91eb284d01f836600bd2e58f;hb=e8d8cb2aba9988608ee98b0a7dfc1053b6429040;hp=190d0f24404678d77b57b3685d5f022bfe671319;hpb=a39837c0ddf444dd98b371eaf8226ad865543519;p=demos%2Fkafka%2Fchat

diff --git a/src/test/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHomeTest.java b/src/test/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHomeTest.java
index 190d0f24..8be31731 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHomeTest.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHomeTest.java
@@ -22,7 +22,7 @@ public class SimpleChatHomeTest extends ChatHomeTest
         Clock clock)
     {
       return new SimpleChatHome(
-          storageStrategy.read(),
+          storageStrategy,
           clock,
           bufferSize());
     }
@@ -32,10 +32,7 @@ public class SimpleChatHomeTest extends ChatHomeTest
     {
       return new FilesStorageStrategy(
           Paths.get("target", "test-classes", "data", "files"),
-          clock,
-          bufferSize(),
           chatRoomId -> 0,
-          messageFlux -> new InMemoryChatRoomService(messageFlux),
           new ObjectMapper());
     }