1 package de.juplo.kafka.chat.backend.domain;
3 import reactor.core.publisher.Flux;
4 import reactor.core.publisher.Mono;
6 import java.time.LocalDateTime;
10 public interface ChatMessageService
14 Mono<Message> persistMessage(
15 Message.MessageKey key,
16 LocalDateTime timestamp,
19 Mono<Message> getMessage(Message.MessageKey key);
21 Flux<Message> getMessages(long first, long last);