From: Kai Moritz <kai@juplo.de>
Date: Sun, 26 Feb 2023 18:29:29 +0000 (+0100)
Subject: WIP:TODO
X-Git-Tag: kafkadata~32
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=2aeb6169a2f362dd342850c638cccb15bf353965;p=demos%2Fkafka%2Fchat

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 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
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 77fe6425..7149603a 100644
--- 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,