X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fapi%2FChatBackendController.java;h=1a8711a0f89790437b5eb01db50804cd5532d0fd;hb=74d8298a250f51a1846a92dadf15126ec9ce46f2;hp=7f29b16c8a33189e71b73f31a698b4e7833a6888;hpb=b87c6c6b04a90193f3c0e6f182d75f89da80ea72;p=demos%2Fkafka%2Fchat diff --git a/src/main/java/de/juplo/kafka/chat/backend/api/ChatBackendController.java b/src/main/java/de/juplo/kafka/chat/backend/api/ChatBackendController.java index 7f29b16c..1a8711a0 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/api/ChatBackendController.java +++ b/src/main/java/de/juplo/kafka/chat/backend/api/ChatBackendController.java @@ -2,7 +2,7 @@ package de.juplo.kafka.chat.backend.api; import de.juplo.kafka.chat.backend.domain.ChatHomeService; import de.juplo.kafka.chat.backend.domain.ChatRoomData; -import de.juplo.kafka.chat.backend.persistence.StorageStrategy; +import de.juplo.kafka.chat.backend.implementation.StorageStrategy; import lombok.RequiredArgsConstructor; import org.springframework.http.codec.ServerSentEvent; import org.springframework.web.bind.annotation.*; @@ -10,6 +10,7 @@ import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import java.util.UUID; +import java.util.logging.Level; @RestController @@ -118,7 +119,10 @@ public class ChatBackendController { return chatRoomData .listen() - .log() + .log( + ChatBackendController.class.getSimpleName(), + Level.FINE, + true) .map(message -> MessageTo.from(message)) .map(messageTo -> ServerSentEvent @@ -128,9 +132,17 @@ public class ChatBackendController .build()); } + @GetMapping("/shards") + public Mono getShardOwners() + { + return chatHomeService.getShardOwners(); + } + @PostMapping("/store") public void store() { - storageStrategy.write(chatHomeService); + storageStrategy + .write(chatHomeService) + .subscribe(); } }