1 package de.juplo.kafka.chat.backend.domain;
4 import reactor.core.publisher.Flux;
5 import reactor.core.publisher.Mono;
7 import java.time.LocalDateTime;
10 public interface PersistenceStrategy
12 Mono<Message> persistMessage(
13 Message.MessageKey key,
14 LocalDateTime timestamp,
17 Mono<Message> getMessage(Message.MessageKey key);
19 Flux<Message> getMessages(long first, long last);