refactore: Renamed `ChatroomFactory` to `ChatHomeService` -- Move

[demos/kafka/chat] / src / main / java / de / juplo / kafka / chat / backend / persistence / StorageStrategy.java

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/StorageStrategy.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/StorageStrategy.java
index 3c268ca..38a9e98 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/StorageStrategy.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/StorageStrategy.java
@@ -1,5 +1,6 @@
 package de.juplo.kafka.chat.backend.persistence;
 
+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;
@@ -9,6 +10,6 @@ public interface StorageStrategy
 {
   void writeChatrooms(Flux<Chatroom> chatroomFlux);
   Flux<Chatroom> readChatrooms();
-  void writeMessages(ChatroomInfo chatroomInfo, Flux<Message> messageFlux);
-  Flux<Message> readMessages(ChatroomInfo chatroomInfo);
+  void writeMessages(ChatroomTo chatroomTo, Flux<Message> messageFlux);
+  Flux<Message> readMessages(ChatroomTo chatroomTo);
 }