package de.juplo.kafka.chat.backend.persistence.kafka;
import de.juplo.kafka.chat.backend.domain.Message;
+import reactor.core.publisher.Mono;
+
+import java.time.LocalDateTime;
interface MessageHandlingStrategy
{
- MessageHandlingStrategy handleMessage(Message message);
+ Mono<Message> handleMessage(
+ Message.MessageKey key,
+ LocalDateTime timestamp,
+ String text);
}