From d150e1428ee567f88f7bc52d3bf3dc1787d7c33b Mon Sep 17 00:00:00 2001 From: Harry Yang Date: Tue, 28 Nov 2023 13:16:25 +0800 Subject: [PATCH] :art: --- .../cn/taketoday/web/socket/StandardEndpoint.java | 2 +- .../cn/taketoday/web/socket/WebSocketHandler.java | 12 ++++++------ .../annotation/AnnotationWebSocketDispatcher.java | 2 +- .../AnnotationWebSocketHandlerBuilder.java | 2 +- .../handler/PerConnectionWebSocketHandler.java | 2 +- 5 files changed, 10 insertions(+), 10 deletions(-) diff --git a/today-websocket/src/main/java/cn/taketoday/web/socket/StandardEndpoint.java b/today-websocket/src/main/java/cn/taketoday/web/socket/StandardEndpoint.java index 229f595b9e..aaaad4b801 100644 --- a/today-websocket/src/main/java/cn/taketoday/web/socket/StandardEndpoint.java +++ b/today-websocket/src/main/java/cn/taketoday/web/socket/StandardEndpoint.java @@ -56,7 +56,7 @@ public void onOpen(Session stdSession, EndpointConfig config) { // The following inner classes need to remain since lambdas would not retain their // declared generic types (which need to be seen by the underlying WebSocket engine) - if (socketHandler.supportPartialMessage()) { + if (socketHandler.supportsPartialMessage()) { stdSession.addMessageHandler(new MessageHandler.Partial() { @Override public void onMessage(String partialMessage, boolean last) { diff --git a/today-websocket/src/main/java/cn/taketoday/web/socket/WebSocketHandler.java b/today-websocket/src/main/java/cn/taketoday/web/socket/WebSocketHandler.java index 3a8381aac3..bad3ff0b71 100644 --- a/today-websocket/src/main/java/cn/taketoday/web/socket/WebSocketHandler.java +++ b/today-websocket/src/main/java/cn/taketoday/web/socket/WebSocketHandler.java @@ -167,33 +167,33 @@ protected void throwNotSupportMessage(Message message) { throw new IllegalArgumentException("Not support message: " + message); } - protected void handlePingMessage(WebSocketSession session, PingMessage message) { + protected void handlePingMessage(WebSocketSession session, PingMessage message) throws Exception { if (delegate != null) { delegate.handlePingMessage(session, message); } } - protected void handlePongMessage(WebSocketSession session, PongMessage message) { + protected void handlePongMessage(WebSocketSession session, PongMessage message) throws Exception { if (delegate != null) { delegate.handlePongMessage(session, message); } } - protected void handleTextMessage(WebSocketSession session, TextMessage message) { + protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception { if (delegate != null) { delegate.handleTextMessage(session, message); } } - protected void handleBinaryMessage(WebSocketSession session, BinaryMessage message) { + protected void handleBinaryMessage(WebSocketSession session, BinaryMessage message) throws Exception { if (delegate != null) { delegate.handleBinaryMessage(session, message); } } - public boolean supportPartialMessage() { + public boolean supportsPartialMessage() { if (delegate != null) { - return delegate.supportPartialMessage(); + return delegate.supportsPartialMessage(); } return false; } diff --git a/today-websocket/src/main/java/cn/taketoday/web/socket/annotation/AnnotationWebSocketDispatcher.java b/today-websocket/src/main/java/cn/taketoday/web/socket/annotation/AnnotationWebSocketDispatcher.java index 62db308d30..ee40b45ccf 100644 --- a/today-websocket/src/main/java/cn/taketoday/web/socket/annotation/AnnotationWebSocketDispatcher.java +++ b/today-websocket/src/main/java/cn/taketoday/web/socket/annotation/AnnotationWebSocketDispatcher.java @@ -131,7 +131,7 @@ public void handleMessage(WebSocketSession session, Message message) { } @Override - public boolean supportPartialMessage() { + public boolean supportsPartialMessage() { return supportPartialMessage; } diff --git a/today-websocket/src/main/java/cn/taketoday/web/socket/annotation/AnnotationWebSocketHandlerBuilder.java b/today-websocket/src/main/java/cn/taketoday/web/socket/annotation/AnnotationWebSocketHandlerBuilder.java index 91d03a0eae..3594c8012b 100644 --- a/today-websocket/src/main/java/cn/taketoday/web/socket/annotation/AnnotationWebSocketHandlerBuilder.java +++ b/today-websocket/src/main/java/cn/taketoday/web/socket/annotation/AnnotationWebSocketHandlerBuilder.java @@ -137,7 +137,7 @@ public WebSocketHandler build(String beanName, BeanDefinition definition, * * @param supportPartialMessage supportPartialMessage? * @see Message#isLast() - * @see WebSocketHandler#supportPartialMessage() + * @see WebSocketHandler#supportsPartialMessage() */ public void setSupportPartialMessage(boolean supportPartialMessage) { this.supportPartialMessage = supportPartialMessage; diff --git a/today-websocket/src/main/java/cn/taketoday/web/socket/handler/PerConnectionWebSocketHandler.java b/today-websocket/src/main/java/cn/taketoday/web/socket/handler/PerConnectionWebSocketHandler.java index 317592acbc..7c0f0a663e 100644 --- a/today-websocket/src/main/java/cn/taketoday/web/socket/handler/PerConnectionWebSocketHandler.java +++ b/today-websocket/src/main/java/cn/taketoday/web/socket/handler/PerConnectionWebSocketHandler.java @@ -99,7 +99,7 @@ public void onClose(WebSocketSession session, CloseStatus status) throws Excepti } @Override - public boolean supportPartialMessage() { + public boolean supportsPartialMessage() { return this.supportsPartialMessages; }