| | |
| | | import org.springframework.web.socket.WebSocketSession; |
| | | import org.springframework.web.socket.handler.TextWebSocketHandler; |
| | | |
| | | /* loaded from: blade-starter-websocket-9.3.0.0-SNAPSHOT.jar:org/springblade/core/websocket/handler/CustomWebSocketHandler.class */ |
| | | public class CustomWebSocketHandler extends TextWebSocketHandler { |
| | | private static final Logger log = LoggerFactory.getLogger(CustomWebSocketHandler.class); |
| | | private static final ObjectMapper MAPPER = new ObjectMapper(); |
| | |
| | | this.planTextMessageHandler = planTextMessageHandler; |
| | | } |
| | | |
| | | @Override |
| | | public void handleTextMessage(WebSocketSession session, TextMessage message) throws JsonProcessingException { |
| | | if (message.getPayloadLength() == 0) { |
| | | return; |