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
}
@Override
- public MessageHandlingStrategy handleMessage(Message message)
+ public Mono<Message> handleMessage(Message.MessageKey key, LocalDateTime timestamp, String text)
{
- // todo
- return this;
+ // TODO
+ return null;
}
}