X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fpersistence%2Fkafka%2FChatRoomLoadingMessageHandlingStrategy.java;h=7149603a76f1c856c06ee76d798cb83e912765e1;hb=220a778c91468046054fac0400ba89825c46b3f5;hp=af99b8092956c9d2d95e71809210ad48e42023c5;hpb=320f2e00a39f4cb7428446223cb9fb2f37d12e25;p=demos%2Fkafka%2Fchat 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 af99b809..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 @@ -3,6 +3,9 @@ package de.juplo.kafka.chat.backend.persistence.kafka; import de.juplo.kafka.chat.backend.domain.Message; import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.common.TopicPartition; +import reactor.core.publisher.Mono; + +import java.time.LocalDateTime; class ChatRoomLoadingMessageHandlingStrategy implements MessageHandlingStrategy @@ -12,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, @@ -27,9 +38,9 @@ class ChatRoomLoadingMessageHandlingStrategy implements MessageHandlingStrategy } @Override - public MessageHandlingStrategy handleMessage(Message message) + public Mono handleMessage(Message.MessageKey key, LocalDateTime timestamp, String text) { - // todo - return this; + // TODO + return null; } }