Add payload to listener

Board-of-Directors · Apr 4, 2024 · 2f7fe4e · 2f7fe4e
1 parent 46ce3d9
commit 2f7fe4e
Showing 1 changed file with 3 additions and 2 deletions.
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
@@ -6,6 +6,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.kafka.annotation.KafkaHandler;
 import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.messaging.handler.annotation.Payload;
 import org.springframework.stereotype.Component;
 import ru.nsu.fit.directors.userservice.event.BusinessMessageEvent;
 import ru.nsu.fit.directors.userservice.service.ChatService;
@@ -18,8 +19,8 @@
 public class ChatTopicListener {
     private final ChatService chatService;
 
-    @KafkaHandler
-    public void handleMessage(BusinessMessageEvent businessMessageEvent) {
+    @KafkaHandler(isDefault = true)
+    public void handleMessage(@Payload BusinessMessageEvent businessMessageEvent) {
         log.info("Receive business message {}", businessMessageEvent);
         chatService.handleMessage(businessMessageEvent);
     }