From 2aeb6169a2f362dd342850c638cccb15bf353965 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 26 Feb 2023 19:29:29 +0100 Subject: [PATCH] WIP:TODO --- .../kafka/ChatRoomActiveMessageHandlingStrategy.java | 5 ++++- .../kafka/ChatRoomLoadingMessageHandlingStrategy.java | 8 ++++++++ 2 files changed, 12 insertions(+), 1 deletion(-) 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, -- 2.20.1