Skip to content

Commit 373bea3

Browse files
committed
feat: 채널 토픽 로그 추가(#87)
1 parent b221a06 commit 373bea3

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

be/src/main/java/yeonba/be/chatting/service/ChatService.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
import java.util.List;
55
import java.util.Optional;
66
import lombok.RequiredArgsConstructor;
7+
import lombok.extern.slf4j.Slf4j;
78
import org.springframework.context.ApplicationEventPublisher;
89
import org.springframework.data.redis.listener.ChannelTopic;
910
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
@@ -32,6 +33,7 @@
3233
import yeonba.be.user.repository.block.BlockQuery;
3334
import yeonba.be.user.repository.user.UserQuery;
3435

36+
@Slf4j
3537
@Service
3638
@RequiredArgsConstructor
3739
public class ChatService {
@@ -164,6 +166,7 @@ public void acceptRequestedChat(long userId, long notificationId) {
164166

165167
// 메시지 수신을 위한 Redis Pub/Sub 구독
166168
container.addMessageListener(adapter, new ChannelTopic(String.valueOf(chatRoom.getId())));
169+
log.info("channel topic 생성 {}", chatRoom.getId());
167170

168171
NotificationSendEvent notificationSendEvent = new NotificationSendEvent(
169172
NotificationType.CHATTING_REQUEST_ACCEPTED, receiver, sender,

0 commit comments

Comments
 (0)