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;
9 public interface ChatRoomService
11 Mono<Message> persistMessage(
12 Message.MessageKey key,
13 LocalDateTime timestamp,
16 Mono<Message> getMessage(Message.MessageKey key);
18 Flux<Message> getMessages(long first, long last);