diff --git a/src/main/kotlin/com/hero/alignlab/ws/handler/ReactiveConcurrentUserWebSocketHandler.kt b/src/main/kotlin/com/hero/alignlab/ws/handler/ReactiveConcurrentUserWebSocketHandler.kt index 487efc4..97a00b7 100644 --- a/src/main/kotlin/com/hero/alignlab/ws/handler/ReactiveConcurrentUserWebSocketHandler.kt +++ b/src/main/kotlin/com/hero/alignlab/ws/handler/ReactiveConcurrentUserWebSocketHandler.kt @@ -40,6 +40,8 @@ class ReactiveConcurrentUserWebSocketHandler( private val concurrentUserByMap: ConcurrentMap> = ConcurrentHashMap() override fun handle(session: WebSocketSession): Mono { + println(">> 접속함") + val groupId = session.handshakeInfo.uri.path .split("/") .lastOrNull { it.matches(Regex("\\d+")) } @@ -57,6 +59,8 @@ class ReactiveConcurrentUserWebSocketHandler( val user = authFacade.resolveAuthUser(authUserToken) + println("concurrent user : ${user.uid}") + val groupUsers = groupUserService.findAllByUidSync(user.uid) groupUsers.forEach { groupUser -> @@ -67,6 +71,7 @@ class ReactiveConcurrentUserWebSocketHandler( concurrentUserByMap[groupUser.groupId] = cuser } + logger.info { "concurrent user ${user.uid}" } concurrentUserByMap.forEach { (groupId, uidBySession) ->