@@ -128,7 +128,7 @@ public void processSdpOffer(KurentoOfferRequest message, StompHeaderAccessor acc
128128 System .out .println ("sdp 처리 및 sdp answer 생성" + sdpAnswer );
129129
130130 // 클라이언트에게 SDP Answer 전송
131- messagingTemplate .convertAndSend ("/topic/webrtc /" + message .data ().roomId (),
131+ messagingTemplate .convertAndSend ("/topic/answer /" + message .data ().roomId (),
132132 new KurentoAnswerResponse ("sdpAnswer" , sdpAnswer ));
133133
134134 // ICE Candidate 수집
@@ -163,7 +163,7 @@ public void startIceCandidateListener(KurentoOfferRequest message, StompHeaderAc
163163 candidateMessage .add ("candidate" , new Gson ().toJsonTree (candidate ));
164164
165165 // ✅ 클라이언트에게 ICE Candidate 전송
166- messagingTemplate .convertAndSend ("/topic/webrtc /" + message .data ().roomId (), candidateMessage .toString ());
166+ messagingTemplate .convertAndSend ("/topic/candidate /" + message .data ().roomId (), candidateMessage .toString ());
167167 });
168168 }
169169
@@ -175,7 +175,7 @@ public void getUsersInChannel(String roomId) {
175175
176176 if (!roomEndpoints .containsKey (roomId )) {
177177 log .warn ("🚨 [Kurento] 조회 실패: 존재하지 않는 채널 (channelId={})" , roomId );
178- messagingTemplate .convertAndSend ("/topic/webrtc /" + roomId , Collections .emptyList ());
178+ messagingTemplate .convertAndSend ("/topic/users /" + roomId , Collections .emptyList ());
179179 return ;
180180 }
181181
@@ -203,7 +203,7 @@ public void getUsersInChannel(String roomId) {
203203 .collect (Collectors .toList ());
204204
205205 // ✅ 클라이언트에게 STOMP 메시지 전송 (유저 목록)
206- messagingTemplate .convertAndSend ("/topic/webrtc /" + roomId , users );
206+ messagingTemplate .convertAndSend ("/topic/users /" + roomId , users );
207207 log .info ("📡 [STOMP] 유저 목록 전송 완료 - roomId: {}, userCount: {}" , roomId , users .size ());
208208 }
209209
0 commit comments