Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'jetty-websocket/websocket-core/src/main/java/org/eclipse/jetty/websocket/io/payload/PayloadProcessor.java')
-rw-r--r--jetty-websocket/websocket-core/src/main/java/org/eclipse/jetty/websocket/io/payload/PayloadProcessor.java24
1 files changed, 24 insertions, 0 deletions
diff --git a/jetty-websocket/websocket-core/src/main/java/org/eclipse/jetty/websocket/io/payload/PayloadProcessor.java b/jetty-websocket/websocket-core/src/main/java/org/eclipse/jetty/websocket/io/payload/PayloadProcessor.java
new file mode 100644
index 0000000000..6cb9816b33
--- /dev/null
+++ b/jetty-websocket/websocket-core/src/main/java/org/eclipse/jetty/websocket/io/payload/PayloadProcessor.java
@@ -0,0 +1,24 @@
+package org.eclipse.jetty.websocket.io.payload;
+
+import java.nio.ByteBuffer;
+
+import org.eclipse.jetty.websocket.api.BadPayloadException;
+import org.eclipse.jetty.websocket.protocol.WebSocketFrame;
+
+/**
+ * Process the payload (for demasking, validating, etc..)
+ */
+public interface PayloadProcessor
+{
+ /**
+ * Used to process payloads for in the spec.
+ *
+ * @param payload
+ * the payload to process
+ * @throws BadPayloadException
+ * the exception when the payload fails to validate properly
+ */
+ public void process(ByteBuffer payload);
+
+ public void reset(WebSocketFrame frame);
+}

Back to the top