X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fapi%2FChatBackendController.java;h=6c7cff7de38056ea93f7804f9da26499a72fb3cc;hb=7107fd0b4795d95b6c7f49cf4e765b82c16d016e;hp=47ae6a5daa6f37279d10e349826c1594ed3349fd;hpb=2800b80bb0a02feb70ab9d0c804b2fcc9915f479;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 47ae6a5d..6c7cff7d 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 @@ -18,6 +18,7 @@ public class ChatBackendController { private final ChatHomeService chatHomeService; private final StorageStrategy storageStrategy; + private final String loggingCategory = ChatBackendController.class.getSimpleName(); private final Level loggingLevel; private final boolean showOperatorLine; @@ -133,7 +134,7 @@ public class ChatBackendController return chatRoomData .listen() .log( - ChatBackendController.class.getSimpleName(), + loggingCategory, loggingLevel, showOperatorLine) .map(message -> MessageTo.from(message))