X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2FChatBackendConfiguration.java;h=87965ab920bbec454adaa7e9485a95a1022493c6;hb=fad1a04e738182403490b11575653e3a1130fd48;hp=dcf2d9f3585e8c12fda57f550b6876415e7e2be0;hpb=182a9d3c21cc4a091290a6b616bbec25b7d2d25a;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 dcf2d9f3..87965ab9 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/ChatBackendConfiguration.java +++ b/src/main/java/de/juplo/kafka/chat/backend/ChatBackendConfiguration.java @@ -32,7 +32,7 @@ public class ChatBackendConfiguration ChatBackendProperties properties) { return new InMemoryChatHomeService( - storageStrategy.readChatrooms(), + storageStrategy.read(), clock, properties.getChatroomBufferSize()); }