Skip to content

Commit

Permalink
🎨
Browse files Browse the repository at this point in the history
  • Loading branch information
TAKETODAY committed Nov 28, 2023
1 parent 1845b42 commit d150e14
Show file tree
Hide file tree
Showing 5 changed files with 10 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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<String>() {
@Override
public void onMessage(String partialMessage, boolean last) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@ public void handleMessage(WebSocketSession session, Message<?> message) {
}

@Override
public boolean supportPartialMessage() {
public boolean supportsPartialMessage() {
return supportPartialMessage;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,7 @@ public void onClose(WebSocketSession session, CloseStatus status) throws Excepti
}

@Override
public boolean supportPartialMessage() {
public boolean supportsPartialMessage() {
return this.supportsPartialMessages;
}

Expand Down

0 comments on commit d150e14

Please sign in to comment.