WIP:TODO

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

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomLoadingMessageHandlingStrategy.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomLoadingMessageHandlingStrategy.java
index 77fe642..7149603 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomLoadingMessageHandlingStrategy.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomLoadingMessageHandlingStrategy.java
@@ -15,6 +15,14 @@ class ChatRoomLoadingMessageHandlingStrategy implements MessageHandlingStrategy
   private final long currentOffset;
   private final long unseenOffset;
 
+  /**
+   * Wird nicht benötigt!!!
+   * Derzeit?
+   * @param consumer
+   * @param tp
+   * @param currentOffset
+   * @param unseenOffset
+   */
   ChatRoomLoadingMessageHandlingStrategy(
       Consumer consumer,
       TopicPartition tp,