X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fpersistence%2Fkafka%2FChatRoomActiveMessageHandlingStrategy.java;h=84484d903d5c53476ea8b26ea59f881889f06e97;hb=3ff99ab559bf06b97c4c282a7933df951cbeaa8f;hp=04564b9c62813dc5f092486f90100506f531a44c;hpb=b44e10be71112a45855d04add6497e40d4c72d24;p=demos%2Fkafka%2Fchat

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 04564b9c..84484d90 100644
--- 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