| | |
| | | import com.qianwen.core.websocket.message.WebSocketMessageTypeEnum; |
| | | import org.springframework.web.socket.WebSocketSession; |
| | | |
| | | /* loaded from: blade-starter-websocket-9.3.0.0-SNAPSHOT.jar:org/springblade/core/websocket/handler/PingJsonMessageHandler.class */ |
| | | public class PingJsonMessageHandler implements JsonMessageHandler<PingJsonWebSocketMessage> { |
| | | @Override // com.qianwen.core.websocket.handler.JsonMessageHandler |
| | | @Override |
| | | public void handle(WebSocketSession session, PingJsonWebSocketMessage message) { |
| | | JsonWebSocketMessage pongJsonWebSocketMessage = new PongJsonWebSocketMessage(); |
| | | WebSocketMessageSender.send(session, pongJsonWebSocketMessage); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.websocket.handler.JsonMessageHandler |
| | | @Override |
| | | public String type() { |
| | | return WebSocketMessageTypeEnum.PING.getValue(); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.websocket.handler.JsonMessageHandler |
| | | @Override |
| | | public Class<PingJsonWebSocketMessage> getMessageClass() { |
| | | return PingJsonWebSocketMessage.class; |
| | | } |