From 47a43169cf751fe4c5fba0e9b889ffa06d4c7723 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 26 Dec 2022 13:48:05 +0100 Subject: [PATCH] feat: Added logging for the `listen`-endpoint --- .../java/de/juplo/kafka/chatroom/api/ChatroomController.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/de/juplo/kafka/chatroom/api/ChatroomController.java b/src/main/java/de/juplo/kafka/chatroom/api/ChatroomController.java index effeccbc..da65a439 100644 --- a/src/main/java/de/juplo/kafka/chatroom/api/ChatroomController.java +++ b/src/main/java/de/juplo/kafka/chatroom/api/ChatroomController.java @@ -71,6 +71,7 @@ public class ChatroomController return chatrooms .get(chatroomId) .listen() + .log() .map(message -> MessageTo.from(message)); } } -- 2.20.1