X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fdomain%2FChatroomService.java;h=1e7e8c72f0d276ad36a4a5a9042ae413022b9388;hb=c04279dc82b8e662f7a8408ff74f7acd9951cf72;hp=d3a8364daaea1b699b47f36cf912480f66aa79ba;hpb=ae2a35f830ce23503deae96600b7c718983792a3;p=demos%2Fkafka%2Fchat diff --git a/src/main/java/de/juplo/kafka/chat/backend/domain/ChatroomService.java b/src/main/java/de/juplo/kafka/chat/backend/domain/ChatroomService.java index d3a8364d..1e7e8c72 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/domain/ChatroomService.java +++ b/src/main/java/de/juplo/kafka/chat/backend/domain/ChatroomService.java @@ -6,7 +6,7 @@ import reactor.core.publisher.Mono; import java.time.LocalDateTime; -public interface PersistenceStrategy +public interface ChatroomService { Mono persistMessage( Message.MessageKey key,