refactor: Moved `FilesStorageStrategy` in its own package -- Move
[demos/kafka/chat] / src / main / java / de / juplo / kafka / chat / backend / persistence / StorageStrategy.java
index a337b61..4355f9f 100644 (file)
@@ -1,6 +1,6 @@
 package de.juplo.kafka.chat.backend.persistence;
 
-import de.juplo.kafka.chat.backend.api.ChatroomTo;
+import de.juplo.kafka.chat.backend.api.ChatRoomTo;
 import de.juplo.kafka.chat.backend.domain.ChatRoom;
 import de.juplo.kafka.chat.backend.domain.Message;
 import reactor.core.publisher.Flux;
@@ -10,6 +10,6 @@ public interface StorageStrategy
 {
   void writeChatrooms(Flux<ChatRoom> chatroomFlux);
   Flux<ChatRoom> readChatrooms();
-  void writeMessages(ChatroomTo chatroomTo, Flux<Message> messageFlux);
-  Flux<Message> readMessages(ChatroomTo chatroomTo);
+  void writeMessages(ChatRoomTo chatroomTo, Flux<Message> messageFlux);
+  Flux<Message> readMessages(ChatRoomTo chatroomTo);
 }