You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@knox.apache.org by su...@apache.org on 2017/01/04 15:53:34 UTC
knox git commit: KNOX-836 Fix for websocket termination based on
message size (Sandeep More via Sumit Gupta)
Repository: knox
Updated Branches:
refs/heads/master 336c7b387 -> fb0dc061f
KNOX-836 Fix for websocket termination based on message size (Sandeep More via Sumit Gupta)
Project: http://git-wip-us.apache.org/repos/asf/knox/repo
Commit: http://git-wip-us.apache.org/repos/asf/knox/commit/fb0dc061
Tree: http://git-wip-us.apache.org/repos/asf/knox/tree/fb0dc061
Diff: http://git-wip-us.apache.org/repos/asf/knox/diff/fb0dc061
Branch: refs/heads/master
Commit: fb0dc061fe1200037d7beed48dcfb23c0877fecf
Parents: 336c7b3
Author: Sumit Gupta <su...@apache.org>
Authored: Wed Jan 4 10:50:53 2017 -0500
Committer: Sumit Gupta <su...@apache.org>
Committed: Wed Jan 4 10:50:53 2017 -0500
----------------------------------------------------------------------
.../org/apache/hadoop/gateway/websockets/ProxyInboundSocket.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/knox/blob/fb0dc061/gateway-server/src/main/java/org/apache/hadoop/gateway/websockets/ProxyInboundSocket.java
----------------------------------------------------------------------
diff --git a/gateway-server/src/main/java/org/apache/hadoop/gateway/websockets/ProxyInboundSocket.java b/gateway-server/src/main/java/org/apache/hadoop/gateway/websockets/ProxyInboundSocket.java
index 39744e1..3c0edaf 100644
--- a/gateway-server/src/main/java/org/apache/hadoop/gateway/websockets/ProxyInboundSocket.java
+++ b/gateway-server/src/main/java/org/apache/hadoop/gateway/websockets/ProxyInboundSocket.java
@@ -63,7 +63,7 @@ public class ProxyInboundSocket {
callback.onError(cause);
}
- @OnMessage
+ @OnMessage(maxMessageSize = Integer.MAX_VALUE)
public void onBackendMessage(final String message,
final javax.websocket.Session session) {
@@ -71,7 +71,7 @@ public class ProxyInboundSocket {
}
- @OnMessage
+ @OnMessage(maxMessageSize = Integer.MAX_VALUE)
public void onBackendMessageBinary(final byte[] message, final boolean last,
final javax.websocket.Session session) {