From b6139d1ca213e297c4b5bc9b7cb3606ab2d2f67a Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 17 Feb 2023 19:12:27 +0100 Subject: [PATCH] WIP --- ...rategy.java => ChatroomInactiveMessageHandlingStrategy.java} | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) rename src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/{NoOpMessageHandlingStrategy.java => ChatroomInactiveMessageHandlingStrategy.java} (84%) diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/NoOpMessageHandlingStrategy.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatroomInactiveMessageHandlingStrategy.java similarity index 84% rename from src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/NoOpMessageHandlingStrategy.java rename to src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatroomInactiveMessageHandlingStrategy.java index c25418a8..430d6ef8 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/NoOpMessageHandlingStrategy.java +++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatroomInactiveMessageHandlingStrategy.java @@ -6,7 +6,7 @@ import org.apache.kafka.common.TopicPartition; @RequiredArgsConstructor -class NoOpMessageHandlingStrategy implements MessageHandlingStrategy +class ChatroomInactiveMessageHandlingStrategy implements MessageHandlingStrategy { private final TopicPartition tp; -- 2.20.1