X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fpersistence%2Fstorage%2Ffiles%2FFilesStorageStrategy.java;h=5d3c067aff5ea4f1f2c85db83fa71a880c8c8290;hb=7dc64266c5675ead8214edb36173b80363e08b1f;hp=d043696c451fe5998892289577b620d029df484b;hpb=9d61871563f4be4850cebca4fad0545d504522c3;p=demos%2Fkafka%2Fchat

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/files/FilesStorageStrategy.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/files/FilesStorageStrategy.java
index d043696c..5d3c067a 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/files/FilesStorageStrategy.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/files/FilesStorageStrategy.java
@@ -103,12 +103,11 @@ public class FilesStorageStrategy implements StorageStrategy
         .from(new JsonFilePublisher<ChatRoomTo>(chatroomsPath(), mapper, type))
         .log()
         .map(chatRoomTo -> new ChatRoom(
-            chatRoomTo.getId(),
-            chatRoomTo.getName(),
-            chatRoomTo.getShard(),
-            clock,
-            factory.create(readMessages(chatRoomTo)),
-            bufferSize));
+              chatRoomTo.getId(),
+              chatRoomTo.getName(),
+              clock,
+              factory.create(readMessages(chatRoomTo)),
+              bufferSize));
   }
 
   public void writeMessages(ChatRoomTo chatroomTo, Flux<Message> messageFlux)