diff options
2 files changed, 4 insertions, 0 deletions
diff --git a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/frames/BinaryFrame.java b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/frames/BinaryFrame.java index b237b541e3..b7c930b2c7 100644 --- a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/frames/BinaryFrame.java +++ b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/frames/BinaryFrame.java @@ -51,6 +51,8 @@ public class BinaryFrame extends DataFrame @Override public Type getType() { + if (getOpCode() == OpCode.CONTINUATION) + return Type.CONTINUATION; return Type.BINARY; } } diff --git a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/frames/TextFrame.java b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/frames/TextFrame.java index 6fc40b8f63..8aeb325315 100644 --- a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/frames/TextFrame.java +++ b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/frames/TextFrame.java @@ -34,6 +34,8 @@ public class TextFrame extends DataFrame @Override public Type getType() { + if (getOpCode() == OpCode.CONTINUATION) + return Type.CONTINUATION; return Type.TEXT; } |