feat: Added logging for the `listen`-endpoint
authorKai Moritz <kai@juplo.de>
Mon, 26 Dec 2022 12:48:05 +0000 (13:48 +0100)
committerKai Moritz <kai@juplo.de>
Mon, 26 Dec 2022 12:48:05 +0000 (13:48 +0100)
src/main/java/de/juplo/kafka/chatroom/api/ChatroomController.java

index effeccb..da65a43 100644 (file)
@@ -71,6 +71,7 @@ public class ChatroomController
     return chatrooms
         .get(chatroomId)
         .listen()
+        .log()
         .map(message -> MessageTo.from(message));
   }
 }