diff --git a/jetty-websocket/websocket-api/src/main/java/org/eclipse/jetty/websocket/api/RemoteEndpoint.java b/jetty-websocket/websocket-api/src/main/java/org/eclipse/jetty/websocket/api/RemoteEndpoint.java index 0b13c57fa3a..5c96d94a55a 100644 --- a/jetty-websocket/websocket-api/src/main/java/org/eclipse/jetty/websocket/api/RemoteEndpoint.java +++ b/jetty-websocket/websocket-api/src/main/java/org/eclipse/jetty/websocket/api/RemoteEndpoint.java @@ -142,18 +142,7 @@ public interface RemoteEndpoint void setBatchMode(BatchMode mode); /** - * Set the maximum number of frames which allowed to be waiting to be sent at any one time. - * The default value is -1, this indicates there is no limit on how many frames can be - * queued to be sent by the implementation. If the limit is exceeded, subsequent frames - * sent are failed with a {@link java.nio.channels.WritePendingException} but - * the connection is not failed and will remain open. - * - * @param maxOutgoingFrames the max number of frames. - */ - void setMaxOutgoingFrames(int maxOutgoingFrames); - - /** - * Get the maximum number of frames which allowed to be waiting to be sent at any one time. + * Get the maximum number of data frames allowed to be waiting to be sent at any one time. * The default value is -1, this indicates there is no limit on how many frames can be * queued to be sent by the implementation. If the limit is exceeded, subsequent frames * sent are failed with a {@link java.nio.channels.WritePendingException} but @@ -163,6 +152,17 @@ public interface RemoteEndpoint */ int getMaxOutgoingFrames(); + /** + * Set the maximum number of data frames allowed to be waiting to be sent at any one time. + * The default value is -1, this indicates there is no limit on how many frames can be + * queued to be sent by the implementation. If the limit is exceeded, subsequent frames + * sent are failed with a {@link java.nio.channels.WritePendingException} but + * the connection is not failed and will remain open. + * + * @param maxOutgoingFrames the max number of frames. + */ + void setMaxOutgoingFrames(int maxOutgoingFrames); + /** * Get the InetSocketAddress for the established connection. * diff --git a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/WebSocketRemoteEndpoint.java b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/WebSocketRemoteEndpoint.java index c047cb9481f..f4aae110026 100644 --- a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/WebSocketRemoteEndpoint.java +++ b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/WebSocketRemoteEndpoint.java @@ -455,18 +455,18 @@ public class WebSocketRemoteEndpoint implements RemoteEndpoint this.batchMode = batchMode; } - @Override - public void setMaxOutgoingFrames(int maxOutgoingFrames) - { - this.maxNumOutgoingFrames = maxOutgoingFrames; - } - @Override public int getMaxOutgoingFrames() { return maxNumOutgoingFrames; } + @Override + public void setMaxOutgoingFrames(int maxOutgoingFrames) + { + this.maxNumOutgoingFrames = maxOutgoingFrames; + } + @Override public void flush() throws IOException {