X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2FChatBackendConfiguration.java;h=b9d1d29c6a1bc9c95a0389020d1982f7a5eae18d;hb=b159d9543cdb96b4d600bff8dacf79a7f5fff20f;hp=b590854e75d58196497a9b80f8ec5e2067b5e0ac;hpb=70ffb4f9a4bf5a3e419e0a39824f7dfb888bb8dc;p=demos%2Fkafka%2Fchat

diff --git a/src/main/java/de/juplo/kafka/chat/backend/ChatBackendConfiguration.java b/src/main/java/de/juplo/kafka/chat/backend/ChatBackendConfiguration.java
index b590854e..b9d1d29c 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/ChatBackendConfiguration.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/ChatBackendConfiguration.java
@@ -30,7 +30,7 @@ public class ChatBackendConfiguration
   public StorageStrategy storageStrategy(
       ChatBackendProperties properties,
       ObjectMapper mapper,
-      ChatroomFactory chatroomFactory)
+      InMemoryChatroomFactory chatroomFactory)
   {
     return new LocalJsonFilesStorageStrategy(
         Paths.get(properties.getDatadir()),
@@ -39,7 +39,7 @@ public class ChatBackendConfiguration
   }
 
   @Bean
-  ChatroomFactory chatroomFactory(ChatBackendProperties properties)
+  InMemoryChatroomFactory chatroomFactory(ChatBackendProperties properties)
   {
     return new InMemoryChatroomFactory(properties.getChatroomBufferSize());
   }