Merge pull request #5235 from eclipse/jetty-10.0.x-Jetty-WS-API-Cleanup

Jetty WebSocket API minor cleanups before Jetty-10 full release
jetty · Sep 9, 2020 · 7a6404d · 7a6404d
2 parents 4ee0aba + 4023944
commit 7a6404d
Show file tree

Hide file tree

Showing 43 changed files with 66 additions and 62 deletions.
diff --git a/jetty-websocket/websocket-jetty-api/src/main/java/module-info.java b/jetty-websocket/websocket-jetty-api/src/main/java/module-info.java
@@ -16,12 +16,14 @@
 // ========================================================================
 //
 
+import org.eclipse.jetty.websocket.api.ExtensionConfig;
+
 module org.eclipse.jetty.websocket.jetty.api
 {
     exports org.eclipse.jetty.websocket.api;
     exports org.eclipse.jetty.websocket.api.annotations;
-    exports org.eclipse.jetty.websocket.api.extensions;
+    exports org.eclipse.jetty.websocket.api.exceptions;
     exports org.eclipse.jetty.websocket.api.util;
 
-    uses org.eclipse.jetty.websocket.api.extensions.ExtensionConfig.Parser;
+    uses ExtensionConfig.Parser;
 }
diff --git a/...socket/websocket-jetty-api/src/main/java/org/eclipse/jetty/websocket/api/CloseStatus.java b/...socket/websocket-jetty-api/src/main/java/org/eclipse/jetty/websocket/api/CloseStatus.java
@@ -23,8 +23,8 @@ public class CloseStatus
     private static final int MAX_CONTROL_PAYLOAD = 125;
     public static final int MAX_REASON_PHRASE = MAX_CONTROL_PAYLOAD - 2;
 
-    private int code;
-    private String phrase;
+    private final int code;
+    private final String phrase;
 
     /**
      * Creates a reason for closing a web socket connection with the given code and reason phrase.

diff --git a/...ocket/api/extensions/ExtensionConfig.java → .../jetty/websocket/api/ExtensionConfig.java b/...ocket/api/extensions/ExtensionConfig.java → .../jetty/websocket/api/ExtensionConfig.java
@@ -16,7 +16,7 @@
 // ========================================================================
 //
 
-package org.eclipse.jetty.websocket.api.extensions;
+package org.eclipse.jetty.websocket.api;
 
 import java.util.Map;
 import java.util.ServiceLoader;

diff --git a/jetty-websocket/websocket-jetty-api/src/main/java/org/eclipse/jetty/websocket/api/Frame.java b/jetty-websocket/websocket-jetty-api/src/main/java/org/eclipse/jetty/websocket/api/Frame.java
@@ -46,7 +46,7 @@ public static Type from(byte op)
             throw new IllegalArgumentException("OpCode " + op + " is not a valid Frame.Type");
         }
 
-        private byte opcode;
+        private final byte opcode;
 
         Type(byte code)
         {

diff --git a/...ket/websocket-jetty-api/src/main/java/org/eclipse/jetty/websocket/api/UpgradeRequest.java b/...ket/websocket-jetty-api/src/main/java/org/eclipse/jetty/websocket/api/UpgradeRequest.java
@@ -24,8 +24,6 @@
 import java.util.List;
 import java.util.Map;
 
-import org.eclipse.jetty.websocket.api.extensions.ExtensionConfig;
-
 /**
  * The HTTP Upgrade to WebSocket Request
  */

diff --git a/...et/websocket-jetty-api/src/main/java/org/eclipse/jetty/websocket/api/UpgradeResponse.java b/...et/websocket-jetty-api/src/main/java/org/eclipse/jetty/websocket/api/UpgradeResponse.java
@@ -22,8 +22,6 @@
 import java.util.Map;
 import java.util.Set;
 
-import org.eclipse.jetty.websocket.api.extensions.ExtensionConfig;
-
 /**
  * The HTTP Upgrade to WebSocket Response
  */

diff --git a/...t/websocket-jetty-api/src/main/java/org/eclipse/jetty/websocket/api/WebSocketAdapter.java b/...t/websocket-jetty-api/src/main/java/org/eclipse/jetty/websocket/api/WebSocketAdapter.java
@@ -39,14 +39,12 @@ public Session getSession()
 
     public boolean isConnected()
     {
-        Session sess = this.session;
-        return (sess != null) && (sess.isOpen());
+        return session.isOpen();
     }
 
     public boolean isNotConnected()
     {
-        Session sess = this.session;
-        return (sess == null) || (!sess.isOpen());
+        return !isConnected();
     }
 
     @Override

diff --git a/...ty/websocket/api/BadPayloadException.java → ...t/api/exceptions/BadPayloadException.java b/...ty/websocket/api/BadPayloadException.java → ...t/api/exceptions/BadPayloadException.java
@@ -16,7 +16,9 @@
 // ========================================================================
 //
 
-package org.eclipse.jetty.websocket.api;
+package org.eclipse.jetty.websocket.api.exceptions;
+
+import org.eclipse.jetty.websocket.api.StatusCode;
 
 /**
  * Exception to terminate the connection because it has received data within a frame payload that was not consistent with the requirements of that frame

diff --git a/...e/jetty/websocket/api/CloseException.java → ...socket/api/exceptions/CloseException.java b/...e/jetty/websocket/api/CloseException.java → ...socket/api/exceptions/CloseException.java
@@ -16,12 +16,12 @@
 // ========================================================================
 //
 
-package org.eclipse.jetty.websocket.api;
+package org.eclipse.jetty.websocket.api.exceptions;
 
 @SuppressWarnings("serial")
 public class CloseException extends WebSocketException
 {
-    private int statusCode;
+    private final int statusCode;
 
     public CloseException(int closeCode, String message)
     {

diff --git a/...socket/api/InvalidWebSocketException.java → ...exceptions/InvalidWebSocketException.java b/...socket/api/InvalidWebSocketException.java → ...exceptions/InvalidWebSocketException.java
@@ -16,8 +16,10 @@
 // ========================================================================
 //
 
-package org.eclipse.jetty.websocket.api;
+package org.eclipse.jetty.websocket.api.exceptions;
 
+import org.eclipse.jetty.websocket.api.WebSocketAdapter;
+import org.eclipse.jetty.websocket.api.WebSocketListener;
 import org.eclipse.jetty.websocket.api.annotations.WebSocket;
 
 /**

diff --git a/...bsocket/api/MessageTooLargeException.java → .../exceptions/MessageTooLargeException.java b/...bsocket/api/MessageTooLargeException.java → .../exceptions/MessageTooLargeException.java
@@ -16,7 +16,9 @@
 // ========================================================================
 //
 
-package org.eclipse.jetty.websocket.api;
+package org.eclipse.jetty.websocket.api.exceptions;
+
+import org.eclipse.jetty.websocket.api.StatusCode;
 
 /**
  * Exception when a message is too large for the internal buffers occurs and should trigger a connection close.

diff --git a/...bsocket/api/PolicyViolationException.java → .../exceptions/PolicyViolationException.java b/...bsocket/api/PolicyViolationException.java → .../exceptions/PolicyViolationException.java
@@ -16,7 +16,9 @@
 // ========================================================================
 //
 
-package org.eclipse.jetty.websocket.api;
+package org.eclipse.jetty.websocket.api.exceptions;
+
+import org.eclipse.jetty.websocket.api.StatusCode;
 
 /**
  * Exception when a violation of policy occurs and should trigger a connection close.

diff --git a/...etty/websocket/api/ProtocolException.java → ...ket/api/exceptions/ProtocolException.java b/...etty/websocket/api/ProtocolException.java → ...ket/api/exceptions/ProtocolException.java
@@ -16,7 +16,9 @@
 // ========================================================================
 //
 
-package org.eclipse.jetty.websocket.api;
+package org.eclipse.jetty.websocket.api.exceptions;
+
+import org.eclipse.jetty.websocket.api.StatusCode;
 
 /**
  * Per spec, a protocol error should result in a Close frame of status code 1002 (PROTOCOL_ERROR)

diff --git a/...jetty/websocket/api/UpgradeException.java → ...cket/api/exceptions/UpgradeException.java b/...jetty/websocket/api/UpgradeException.java → ...cket/api/exceptions/UpgradeException.java
@@ -16,7 +16,7 @@
 // ========================================================================
 //
 
-package org.eclipse.jetty.websocket.api;
+package org.eclipse.jetty.websocket.api.exceptions;
 
 import java.net.URI;
 

diff --git a/...tty/websocket/api/WebSocketException.java → ...et/api/exceptions/WebSocketException.java b/...tty/websocket/api/WebSocketException.java → ...et/api/exceptions/WebSocketException.java
@@ -16,7 +16,7 @@
 // ========================================================================
 //
 
-package org.eclipse.jetty.websocket.api;
+package org.eclipse.jetty.websocket.api.exceptions;
 
 /**
  * A recoverable exception within the websocket framework.

diff --git a/...socket/api/WebSocketTimeoutException.java → ...exceptions/WebSocketTimeoutException.java b/...socket/api/WebSocketTimeoutException.java → ...exceptions/WebSocketTimeoutException.java
@@ -16,7 +16,7 @@
 // ========================================================================
 //
 
-package org.eclipse.jetty.websocket.api;
+package org.eclipse.jetty.websocket.api.exceptions;
 
 /**
  * Exception thrown to indicate a connection I/O timeout.

diff --git a/...ebsocket/api/extensions/package-info.java → ...ebsocket/api/exceptions/package-info.java b/...ebsocket/api/extensions/package-info.java → ...ebsocket/api/exceptions/package-info.java
@@ -17,7 +17,7 @@
 //
 
 /**
- * Jetty WebSocket API : WebSocket Extension API
+ * Jetty WebSocket API : Exception Types
  */
-package org.eclipse.jetty.websocket.api.extensions;
+package org.eclipse.jetty.websocket.api.exceptions;
 
diff --git a/...bsocket/websocket-jetty-api/src/main/java/org/eclipse/jetty/websocket/api/util/WSURI.java b/...bsocket/websocket-jetty-api/src/main/java/org/eclipse/jetty/websocket/api/util/WSURI.java
@@ -22,8 +22,6 @@
 import java.net.URISyntaxException;
 import java.util.Objects;
 
-// @checkstyle-disable-check : AbbreviationAsWordInNameCheck
-
 /**
  * Utility methods for converting a {@link URI} between a HTTP(S) and WS(S) URI.
  */

diff --git a/...tty/websocket/api/WebSocketConstants.java → ...ebsocket/api/util/WebSocketConstants.java b/...tty/websocket/api/WebSocketConstants.java → ...ebsocket/api/util/WebSocketConstants.java
@@ -16,7 +16,7 @@
 // ========================================================================
 //
 
-package org.eclipse.jetty.websocket.api;
+package org.eclipse.jetty.websocket.api.util;
 
 public final class WebSocketConstants
 {

diff --git a/...t-jetty-client/src/main/java/org/eclipse/jetty/websocket/client/ClientUpgradeRequest.java b/...t-jetty-client/src/main/java/org/eclipse/jetty/websocket/client/ClientUpgradeRequest.java
@@ -31,9 +31,9 @@
 
 import org.eclipse.jetty.http.HttpHeader;
 import org.eclipse.jetty.http.HttpScheme;
+import org.eclipse.jetty.websocket.api.ExtensionConfig;
 import org.eclipse.jetty.websocket.api.UpgradeRequest;
 import org.eclipse.jetty.websocket.api.UpgradeResponse;
-import org.eclipse.jetty.websocket.api.extensions.ExtensionConfig;
 
 /**
  * Client based UpgradeRequest API

diff --git a/...main/java/org/eclipse/jetty/websocket/client/impl/DelegatedJettyClientUpgradeRequest.java b/...main/java/org/eclipse/jetty/websocket/client/impl/DelegatedJettyClientUpgradeRequest.java
@@ -32,8 +32,8 @@
 import org.eclipse.jetty.io.EndPoint;
 import org.eclipse.jetty.util.MultiMap;
 import org.eclipse.jetty.util.UrlEncoded;
+import org.eclipse.jetty.websocket.api.ExtensionConfig;
 import org.eclipse.jetty.websocket.api.UpgradeRequest;
-import org.eclipse.jetty.websocket.api.extensions.ExtensionConfig;
 import org.eclipse.jetty.websocket.core.client.CoreClientUpgradeRequest;
 
 import static java.nio.charset.StandardCharsets.UTF_8;

diff --git a/...ain/java/org/eclipse/jetty/websocket/client/impl/DelegatedJettyClientUpgradeResponse.java b/...ain/java/org/eclipse/jetty/websocket/client/impl/DelegatedJettyClientUpgradeResponse.java
@@ -26,8 +26,8 @@
 
 import org.eclipse.jetty.client.HttpResponse;
 import org.eclipse.jetty.http.HttpHeader;
+import org.eclipse.jetty.websocket.api.ExtensionConfig;
 import org.eclipse.jetty.websocket.api.UpgradeResponse;
-import org.eclipse.jetty.websocket.api.extensions.ExtensionConfig;
 
 /**
  * Representing the Jetty {@link org.eclipse.jetty.client.HttpClient}'s {@link org.eclipse.jetty.client.HttpResponse}

diff --git a/jetty-websocket/websocket-jetty-common/src/main/java/module-info.java b/jetty-websocket/websocket-jetty-common/src/main/java/module-info.java
@@ -16,7 +16,7 @@
 // ========================================================================
 //
 
-import org.eclipse.jetty.websocket.api.extensions.ExtensionConfig;
+import org.eclipse.jetty.websocket.api.ExtensionConfig;
 import org.eclipse.jetty.websocket.common.ExtensionConfigParser;
 
 module org.eclipse.jetty.websocket.jetty.common

diff --git a/...-jetty-common/src/main/java/org/eclipse/jetty/websocket/common/ExtensionConfigParser.java b/...-jetty-common/src/main/java/org/eclipse/jetty/websocket/common/ExtensionConfigParser.java
@@ -20,7 +20,7 @@
 
 import org.eclipse.jetty.websocket.core.ExtensionConfig;
 
-public class ExtensionConfigParser implements org.eclipse.jetty.websocket.api.extensions.ExtensionConfig.Parser
+public class ExtensionConfigParser implements org.eclipse.jetty.websocket.api.ExtensionConfig.Parser
 {
     /**
      * Parse a single parameterized name.

diff --git a/...t-jetty-common/src/main/java/org/eclipse/jetty/websocket/common/JettyExtensionConfig.java b/...t-jetty-common/src/main/java/org/eclipse/jetty/websocket/common/JettyExtensionConfig.java
@@ -26,7 +26,7 @@
 /**
  * Represents an Extension Configuration, as seen during the connection Handshake process.
  */
-public class JettyExtensionConfig implements org.eclipse.jetty.websocket.api.extensions.ExtensionConfig
+public class JettyExtensionConfig implements org.eclipse.jetty.websocket.api.ExtensionConfig
 {
 
     private final ExtensionConfig config;

diff --git a/...y-common/src/main/java/org/eclipse/jetty/websocket/common/JettyWebSocketFrameHandler.java b/...y-common/src/main/java/org/eclipse/jetty/websocket/common/JettyWebSocketFrameHandler.java
@@ -507,27 +507,27 @@ private void demand()
     public static Throwable convertCause(Throwable cause)
     {
         if (cause instanceof MessageTooLargeException)
-            return new org.eclipse.jetty.websocket.api.MessageTooLargeException(cause.getMessage(), cause);
+            return new org.eclipse.jetty.websocket.api.exceptions.MessageTooLargeException(cause.getMessage(), cause);
 
         if (cause instanceof ProtocolException)
-            return new org.eclipse.jetty.websocket.api.ProtocolException(cause.getMessage(), cause);
+            return new org.eclipse.jetty.websocket.api.exceptions.ProtocolException(cause.getMessage(), cause);
 
         if (cause instanceof BadPayloadException)
-            return new org.eclipse.jetty.websocket.api.BadPayloadException(cause.getMessage(), cause);
+            return new org.eclipse.jetty.websocket.api.exceptions.BadPayloadException(cause.getMessage(), cause);
 
         if (cause instanceof CloseException)
-            return new org.eclipse.jetty.websocket.api.CloseException(((CloseException)cause).getStatusCode(), cause.getMessage(), cause);
+            return new org.eclipse.jetty.websocket.api.exceptions.CloseException(((CloseException)cause).getStatusCode(), cause.getMessage(), cause);
 
         if (cause instanceof WebSocketTimeoutException)
-            return new org.eclipse.jetty.websocket.api.WebSocketTimeoutException(cause.getMessage(), cause);
+            return new org.eclipse.jetty.websocket.api.exceptions.WebSocketTimeoutException(cause.getMessage(), cause);
 
         if (cause instanceof InvalidSignatureException)
-            return new org.eclipse.jetty.websocket.api.InvalidWebSocketException(cause.getMessage(), cause);
+            return new org.eclipse.jetty.websocket.api.exceptions.InvalidWebSocketException(cause.getMessage(), cause);
 
         if (cause instanceof UpgradeException)
         {
             UpgradeException ue = (UpgradeException)cause;
-            return new org.eclipse.jetty.websocket.api.UpgradeException(ue.getRequestURI(), ue.getResponseStatusCode(), cause);
+            return new org.eclipse.jetty.websocket.api.exceptions.UpgradeException(ue.getRequestURI(), ue.getResponseStatusCode(), cause);
         }
 
         return cause;

diff --git a/.../src/main/java/org/eclipse/jetty/websocket/common/JettyWebSocketFrameHandlerMetadata.java b/.../src/main/java/org/eclipse/jetty/websocket/common/JettyWebSocketFrameHandlerMetadata.java
@@ -21,7 +21,7 @@
 import java.lang.invoke.MethodHandle;
 
 import org.eclipse.jetty.websocket.api.BatchMode;
-import org.eclipse.jetty.websocket.api.InvalidWebSocketException;
+import org.eclipse.jetty.websocket.api.exceptions.InvalidWebSocketException;
 import org.eclipse.jetty.websocket.core.Configuration;
 import org.eclipse.jetty.websocket.util.messages.MessageSink;
 

diff --git a/...ket.api.extensions.ExtensionConfig$Parser → ...etty.websocket.api.ExtensionConfig$Parser b/...ket.api.extensions.ExtensionConfig$Parser → ...etty.websocket.api.ExtensionConfig$Parser
diff --git a/...ty-common/src/test/java/org/eclipse/jetty/websocket/common/LocalEndpointMetadataTest.java b/...ty-common/src/test/java/org/eclipse/jetty/websocket/common/LocalEndpointMetadataTest.java
@@ -18,7 +18,7 @@
 
 package org.eclipse.jetty.websocket.common;
 
-import org.eclipse.jetty.websocket.api.InvalidWebSocketException;
+import org.eclipse.jetty.websocket.api.exceptions.InvalidWebSocketException;
 import org.eclipse.jetty.websocket.util.DuplicateAnnotationException;
 import org.eclipse.jetty.websocket.util.InvalidSignatureException;
 import org.eclipse.jetty.websocket.util.messages.ByteArrayMessageSink;

diff --git a/...y-server/src/main/java/org/eclipse/jetty/websocket/server/JettyServerUpgradeResponse.java b/...y-server/src/main/java/org/eclipse/jetty/websocket/server/JettyServerUpgradeResponse.java
@@ -21,9 +21,9 @@
 import java.io.IOException;
 import java.util.List;
 
+import org.eclipse.jetty.websocket.api.ExtensionConfig;
 import org.eclipse.jetty.websocket.api.UpgradeRequest;
 import org.eclipse.jetty.websocket.api.UpgradeResponse;
-import org.eclipse.jetty.websocket.api.extensions.ExtensionConfig;
 
 public interface JettyServerUpgradeResponse extends UpgradeResponse
 {

diff --git a/...erver/src/main/java/org/eclipse/jetty/websocket/server/JettyWebSocketServerContainer.java b/...erver/src/main/java/org/eclipse/jetty/websocket/server/JettyWebSocketServerContainer.java
@@ -150,7 +150,7 @@ public void addMapping(String pathSpec, final Class<?> endpointClass)
             }
             catch (Exception e)
             {
-                throw new org.eclipse.jetty.websocket.api.WebSocketException("Unable to create instance of " + endpointClass.getName(), e);
+                throw new org.eclipse.jetty.websocket.api.exceptions.WebSocketException("Unable to create instance of " + endpointClass.getName(), e);
             }
         });
     }

diff --git a/.../main/java/org/eclipse/jetty/websocket/server/internal/DelegatedServerUpgradeRequest.java b/.../main/java/org/eclipse/jetty/websocket/server/internal/DelegatedServerUpgradeRequest.java
@@ -31,7 +31,7 @@
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpSession;
 
-import org.eclipse.jetty.websocket.api.extensions.ExtensionConfig;
+import org.eclipse.jetty.websocket.api.ExtensionConfig;
 import org.eclipse.jetty.websocket.common.JettyExtensionConfig;
 import org.eclipse.jetty.websocket.server.JettyServerUpgradeRequest;
 import org.eclipse.jetty.websocket.util.server.internal.ServerUpgradeRequest;

diff --git a/...main/java/org/eclipse/jetty/websocket/server/internal/DelegatedServerUpgradeResponse.java b/...main/java/org/eclipse/jetty/websocket/server/internal/DelegatedServerUpgradeResponse.java
@@ -24,7 +24,7 @@
 import java.util.Set;
 import java.util.stream.Collectors;
 
-import org.eclipse.jetty.websocket.api.extensions.ExtensionConfig;
+import org.eclipse.jetty.websocket.api.ExtensionConfig;
 import org.eclipse.jetty.websocket.common.JettyExtensionConfig;
 import org.eclipse.jetty.websocket.server.JettyServerUpgradeResponse;
 import org.eclipse.jetty.websocket.util.server.internal.ServerUpgradeResponse;

diff --git a/...tty-server/src/test/java/org/eclipse/jetty/websocket/server/browser/BrowserDebugTool.java b/...tty-server/src/test/java/org/eclipse/jetty/websocket/server/browser/BrowserDebugTool.java
@@ -37,7 +37,7 @@
 import org.eclipse.jetty.toolchain.test.MavenTestingUtils;
 import org.eclipse.jetty.util.resource.PathResource;
 import org.eclipse.jetty.util.resource.Resource;
-import org.eclipse.jetty.websocket.api.extensions.ExtensionConfig;
+import org.eclipse.jetty.websocket.api.ExtensionConfig;
 import org.eclipse.jetty.websocket.server.JettyServerUpgradeRequest;
 import org.eclipse.jetty.websocket.server.JettyServerUpgradeResponse;
 import org.eclipse.jetty.websocket.server.JettyWebSocketCreator;

diff --git a/...ts/src/test/java/org/eclipse/jetty/websocket/tests/JettyWebSocketExtensionConfigTest.java b/...ts/src/test/java/org/eclipse/jetty/websocket/tests/JettyWebSocketExtensionConfigTest.java
@@ -30,8 +30,8 @@
 import org.eclipse.jetty.server.Server;
 import org.eclipse.jetty.server.ServerConnector;
 import org.eclipse.jetty.servlet.ServletContextHandler;
+import org.eclipse.jetty.websocket.api.ExtensionConfig;
 import org.eclipse.jetty.websocket.api.Session;
-import org.eclipse.jetty.websocket.api.extensions.ExtensionConfig;
 import org.eclipse.jetty.websocket.client.ClientUpgradeRequest;
 import org.eclipse.jetty.websocket.client.JettyUpgradeListener;
 import org.eclipse.jetty.websocket.client.WebSocketClient;

diff --git a/...t-jetty-tests/src/test/java/org/eclipse/jetty/websocket/tests/WebSocketOverHTTP2Test.java b/...t-jetty-tests/src/test/java/org/eclipse/jetty/websocket/tests/WebSocketOverHTTP2Test.java
@@ -59,7 +59,7 @@
 import org.eclipse.jetty.util.thread.QueuedThreadPool;
 import org.eclipse.jetty.websocket.api.Session;
 import org.eclipse.jetty.websocket.api.StatusCode;
-import org.eclipse.jetty.websocket.api.UpgradeException;
+import org.eclipse.jetty.websocket.api.exceptions.UpgradeException;
 import org.eclipse.jetty.websocket.client.WebSocketClient;
 import org.eclipse.jetty.websocket.server.JettyWebSocketServlet;
 import org.eclipse.jetty.websocket.server.JettyWebSocketServletFactory;

diff --git a/...t-jetty-tests/src/test/java/org/eclipse/jetty/websocket/tests/client/ClientCloseTest.java b/...t-jetty-tests/src/test/java/org/eclipse/jetty/websocket/tests/client/ClientCloseTest.java
@@ -37,12 +37,12 @@
 import org.eclipse.jetty.servlet.ServletHolder;
 import org.eclipse.jetty.util.BlockingArrayQueue;
 import org.eclipse.jetty.websocket.api.Frame;
-import org.eclipse.jetty.websocket.api.MessageTooLargeException;
 import org.eclipse.jetty.websocket.api.Session;
 import org.eclipse.jetty.websocket.api.StatusCode;
 import org.eclipse.jetty.websocket.api.WebSocketFrameListener;
 import org.eclipse.jetty.websocket.api.WebSocketListener;
-import org.eclipse.jetty.websocket.api.WebSocketTimeoutException;
+import org.eclipse.jetty.websocket.api.exceptions.MessageTooLargeException;
+import org.eclipse.jetty.websocket.api.exceptions.WebSocketTimeoutException;
 import org.eclipse.jetty.websocket.api.util.WSURI;
 import org.eclipse.jetty.websocket.client.WebSocketClient;
 import org.eclipse.jetty.websocket.core.CloseStatus;