X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2FChatBackendConfiguration.java;h=657086282e130c9838309698854da7e10a1d8720;hb=af3553a0f5093819fc2af088b974375c7102ed9d;hp=68ccc4fe6a1aab240fac9f0e3139e9752577aebf;hpb=212c5eb7912fd15768ddab961d104b27acc620a0;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 68ccc4fe..65708628 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/ChatBackendConfiguration.java +++ b/src/main/java/de/juplo/kafka/chat/backend/ChatBackendConfiguration.java @@ -43,7 +43,7 @@ public class ChatBackendConfiguration ObjectMapper mapper) { return new LocalJsonFilesStorageStrategy( - Paths.get(properties.getDatadir()), + Paths.get(properties.getStorageDirectory()), clock, properties.getChatroomBufferSize(), mapper);