X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fpersistence%2FAbstractInMemoryStorageIT.java;h=bff02a361ed3ec0316c942e59f4d3ba1c3843b2b;hb=9c436440fd08e717cd893da4f75a8e79e9a1b9df;hp=832ebd99d8aabfb637409eb3637278038f5a8bd9;hpb=977b454a542b95a5d08a94dd5f8b55814350b7cd;p=demos%2Fkafka%2Fchat

diff --git a/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractInMemoryStorageIT.java b/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractInMemoryStorageIT.java
index 832ebd99..bff02a36 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractInMemoryStorageIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractInMemoryStorageIT.java
@@ -1,9 +1,10 @@
 package de.juplo.kafka.chat.backend.persistence;
 
-import de.juplo.kafka.chat.backend.domain.ChatHomeService;
+import de.juplo.kafka.chat.backend.domain.ChatHome;
 import de.juplo.kafka.chat.backend.domain.ChatRoomFactory;
 import de.juplo.kafka.chat.backend.persistence.inmemory.InMemoryChatHomeService;
 import de.juplo.kafka.chat.backend.persistence.inmemory.InMemoryChatRoomFactory;
+import de.juplo.kafka.chat.backend.persistence.inmemory.SimpleChatHome;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
@@ -21,20 +22,23 @@ public abstract class AbstractInMemoryStorageIT extends AbstractStorageStrategyI
   {
     return new StorageStrategyITConfig()
     {
-      InMemoryChatHomeService chatHomeService = new InMemoryChatHomeService(
+      InMemoryChatHomeService inMemoryChatHomeService = new InMemoryChatHomeService(
           1,
           new int[] { 0 },
           getStorageStrategy().read());
 
+      SimpleChatHome simpleChatHome = new SimpleChatHome(inMemoryChatHomeService);
+
       InMemoryChatRoomFactory chatRoomFactory = new InMemoryChatRoomFactory(
+          inMemoryChatHomeService,
           chatRoomId -> 0,
           clock,
           8);
 
       @Override
-      public ChatHomeService getChatHomeService()
+      public ChatHome getChatHome()
       {
-        return chatHomeService;
+        return simpleChatHome;
       }
 
       @Override