X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fdomain%2FChatroom.java;h=2261e022e201e4a436ae50e542017c4077da13a2;hb=082c283842990180b23f8a35fb3dfa4ebc8a5189;hp=60f7274e813398bd8050d1af55d27552fdfd81cb;hpb=985e677499e8a3a6efcfbf3b3a4c90181194ff27;p=demos%2Fkafka%2Fchat diff --git a/src/main/java/de/juplo/kafka/chat/backend/domain/Chatroom.java b/src/main/java/de/juplo/kafka/chat/backend/domain/Chatroom.java index 60f7274e..2261e022 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/domain/Chatroom.java +++ b/src/main/java/de/juplo/kafka/chat/backend/domain/Chatroom.java @@ -17,19 +17,19 @@ public class Chatroom private final UUID id; @Getter private final String name; - private final PersistenceStrategy persistence; + private final ChatroomService chatroomService; private final int bufferSize; private Sinks.Many sink; public Chatroom( UUID id, String name, - PersistenceStrategy persistence, + ChatroomService chatroomService, int bufferSize) { this.id = id; this.name = name; - this.persistence = persistence; + this.chatroomService = chatroomService; this.bufferSize = bufferSize; this.sink = createSink(); } @@ -41,7 +41,7 @@ public class Chatroom String user, String text) { - return persistence + return chatroomService .persistMessage(Message.MessageKey.of(user, id), timestamp, text) .doOnNext(message -> { @@ -56,7 +56,8 @@ public class Chatroom public Mono getMessage(String username, Long messageId) { - return persistence.getMessage(Message.MessageKey.of(username, messageId)); + Message.MessageKey key = Message.MessageKey.of(username, messageId); + return chatroomService.getMessage(key); } synchronized public Flux listen() @@ -73,7 +74,7 @@ public class Chatroom public Flux getMessages(long first, long last) { - return persistence.getMessages(first, last); + return chatroomService.getMessages(first, last); } private Sinks.Many createSink()