1 package de.juplo.kafka.chat.backend.persistence.kafka;
3 import de.juplo.kafka.chat.backend.domain.Message;
4 import reactor.core.publisher.Mono;
6 import java.time.LocalDateTime;
9 interface MessageHandlingStrategy
11 Mono<Message> handleMessage(
12 Message.MessageKey key,
13 LocalDateTime timestamp,