| | |
| | | * |
| | | * 基于 {@link JsonWebSocketMessage#getType()} 消息类型,调度到对应的 {@link WebSocketMessageListener} 监听器。 |
| | | * |
| | | * @author 芋道源码 |
| | | * @author 超级管理员 |
| | | */ |
| | | @Slf4j |
| | | public class JsonWebSocketMessageHandler extends TextWebSocketHandler { |
| | |
| | | Long tenantId = WebSocketFrameworkUtils.getTenantId(session); |
| | | TenantUtils.execute(tenantId, () -> messageListener.onMessage(session, messageObj)); |
| | | } catch (Throwable ex) { |
| | | log.error("[handleTextMessage][session({}) message({}) 处理异常]", session.getId(), message.getPayload()); |
| | | log.error("[handleTextMessage][session({}) message({}) 处理异常]", session.getId(), message.getPayload(), ex); |
| | | } |
| | | } |
| | | |