NEU

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

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomActiveMessageHandlingStrategy.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomActiveMessageHandlingStrategy.java
index 04564b9..84484d9 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomActiveMessageHandlingStrategy.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomActiveMessageHandlingStrategy.java
@@ -13,6 +13,10 @@ import java.time.ZoneOffset;
 import java.util.UUID;
 
 
+/**
+ * Derzeit eigentlich einzige aktive Strategie!
+ * Rückbau?!?!
+ */
 @RequiredArgsConstructor
 @Slf4j
 class ChatRoomActiveMessageHandlingStrategy implements MessageHandlingStrategy
@@ -22,7 +26,6 @@ class ChatRoomActiveMessageHandlingStrategy implements MessageHandlingStrategy
   private final TopicPartition tp;
   private final UUID chatRoomId;
   private final ZoneOffset zoneOffset;
-  private final KafkaChatRoomService chatRoomService;
 
 
   @Override