Skip to content

Commit

Permalink
Add trusted packages
Browse files Browse the repository at this point in the history
  • Loading branch information
Fagorym committed Apr 3, 2024
1 parent 1fb4415 commit b43de8c
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -18,6 +20,7 @@ public class ChatTopicListener {

@KafkaHandler
public void handleMessage(BusinessMessageEvent businessMessageEvent) {
log.info("Receive business message {}", businessMessageEvent);
chatService.handleMessage(businessMessageEvent);
}
}

0 comments on commit b43de8c

Please sign in to comment.