X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fapi%2FChatBackendController.java;h=d0d276342037ea3939a555d0bececac688578085;hb=8adc14c2abeacb3605b0638afa95b1e4eea9e087;hp=e7a6f1a5bd9e801d71d75af6a7d36f0c6ad2b8dc;hpb=212c5eb7912fd15768ddab961d104b27acc620a0;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 e7a6f1a5..d0d27634 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 @@ -32,7 +32,7 @@ public class ChatBackendController return chatHome.getChatRooms().map(chatroom -> ChatRoomTo.from(chatroom)); } - @GetMapping("list/{chatroomId}") + @GetMapping("{chatroomId}/list") public Flux list(@PathVariable UUID chatroomId) { return chatHome @@ -42,13 +42,13 @@ public class ChatBackendController .map(MessageTo::from)); } - @GetMapping("get/{chatroomId}") + @GetMapping("{chatroomId}") public Mono get(@PathVariable UUID chatroomId) { return chatHome.getChatRoom(chatroomId).map(chatroom -> ChatRoomTo.from(chatroom)); } - @PutMapping("put/{chatroomId}/{username}/{messageId}") + @PutMapping("{chatroomId}/{username}/{messageId}") public Mono put( @PathVariable UUID chatroomId, @PathVariable String username, @@ -76,7 +76,7 @@ public class ChatBackendController .map(message -> MessageTo.from(message)); } - @GetMapping("get/{chatroomId}/{username}/{messageId}") + @GetMapping("{chatroomId}/{username}/{messageId}") public Mono get( @PathVariable UUID chatroomId, @PathVariable String username, @@ -99,7 +99,7 @@ public class ChatBackendController .map(message -> MessageTo.from(message)); } - @GetMapping(path = "listen/{chatroomId}") + @GetMapping(path = "{chatroomId}/listen") public Flux> listen(@PathVariable UUID chatroomId) { return chatHome @@ -124,6 +124,6 @@ public class ChatBackendController @PostMapping("/store") public void store() { - storageStrategy.writeChatrooms(chatHome.getChatRooms()); + storageStrategy.write(chatHome.getChatRooms()); } }