Skip to content

Commit 4952d39

Browse files
committed
hotfix : add log
1 parent 55bbc77 commit 4952d39

1 file changed

Lines changed: 20 additions & 3 deletions

File tree

‎src/main/java/ita/tinybite/domain/chat/service/ChatEventListener.java‎

Lines changed: 20 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,16 @@
11
package ita.tinybite.domain.chat.service;
22

33
import lombok.RequiredArgsConstructor;
4+
import lombok.extern.slf4j.Slf4j;
45
import org.springframework.context.event.EventListener;
56
import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
67
import org.springframework.stereotype.Component;
7-
import org.springframework.web.socket.messaging.SessionDisconnectEvent;
8-
import org.springframework.web.socket.messaging.SessionSubscribeEvent;
9-
import org.springframework.web.socket.messaging.SessionUnsubscribeEvent;
8+
import org.springframework.web.socket.messaging.*;
109

1110
/**
1211
* subscribe, unsubscribe, disconnect 이벤트 발생 시 registry에 자동으로 값을 변경하는 스프링 빈 클래스
1312
*/
13+
@Slf4j
1414
@Component
1515
@RequiredArgsConstructor
1616
public class ChatEventListener {
@@ -59,6 +59,10 @@ public void onUnsubscribe(SessionUnsubscribeEvent event) {
5959

6060
@EventListener
6161
public void onDisconnect(SessionDisconnectEvent event) {
62+
StompHeaderAccessor accessor = StompHeaderAccessor.wrap(event.getMessage());
63+
log.info("[STOMP] DISCONNECT sessionId={}", accessor.getSessionId());
64+
log.info("[STOMP] headers={}", accessor.toNativeHeaderMap());
65+
6266
StompHeaderAccessor acc = StompHeaderAccessor.wrap(event.getMessage());
6367

6468
String sessionId = acc.getSessionId();
@@ -81,4 +85,17 @@ private Long extractRoomId(String destination) {
8185
return null;
8286
}
8387
}
88+
89+
@EventListener
90+
public void onConnect(SessionConnectEvent event) {
91+
StompHeaderAccessor accessor = StompHeaderAccessor.wrap(event.getMessage());
92+
log.info("[STOMP] CONNECT sessionId={}", accessor.getSessionId());
93+
log.info("[STOMP] headers={}", accessor.toNativeHeaderMap());
94+
}
95+
96+
@EventListener
97+
public void onConnected(SessionConnectedEvent event) {
98+
StompHeaderAccessor accessor = StompHeaderAccessor.wrap(event.getMessage());
99+
log.info("[STOMP] CONNECTED sessionId={}", accessor.getSessionId());
100+
}
84101
}

0 commit comments

Comments
 (0)