+ .log(
+ ChatBackendController.class.getSimpleName(),
+ Level.FINE,
+ true)
+ .map(message -> MessageTo.from(message))
+ .map(messageTo ->
+ ServerSentEvent
+ .builder(messageTo)
+ .id(messageTo.getSerial().toString())
+ .event("message")
+ .build());
+ }
+
+ @GetMapping("/shards")
+ public Mono<String[]> getShardOwners()
+ {
+ return chatHomeService.getShardOwners();
+ }
+
+ @PostMapping("/store")
+ public void store()
+ {
+ storageStrategy
+ .write(chatHomeService)
+ .subscribe();