diff --git a/src/main/java/ru/nsu/fit/directors/userservice/listener/ChatTopicListener.java b/src/main/java/ru/nsu/fit/directors/userservice/listener/ChatTopicListener.java index 3b42ddf..d80157b 100644 --- a/src/main/java/ru/nsu/fit/directors/userservice/listener/ChatTopicListener.java +++ b/src/main/java/ru/nsu/fit/directors/userservice/listener/ChatTopicListener.java @@ -3,12 +3,14 @@ import javax.annotation.ParametersAreNonnullByDefault; import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; import org.springframework.kafka.annotation.KafkaHandler; import org.springframework.kafka.annotation.KafkaListener; import org.springframework.stereotype.Component; import ru.nsu.fit.directors.userservice.event.BusinessMessageEvent; import ru.nsu.fit.directors.userservice.service.ChatService; +@Slf4j @Component @RequiredArgsConstructor @ParametersAreNonnullByDefault @@ -18,6 +20,7 @@ public class ChatTopicListener { @KafkaHandler public void handleMessage(BusinessMessageEvent businessMessageEvent) { + log.info("Receive business message {}", businessMessageEvent); chatService.handleMessage(businessMessageEvent); } }