org.springframework.integration.x.ip.websocket
Class WebSocketSerializer
java.lang.Object
org.springframework.integration.x.ip.serializer.AbstractHttpSwitchingDeserializer
org.springframework.integration.x.ip.websocket.WebSocketSerializer
- All Implemented Interfaces:
- org.springframework.core.serializer.Deserializer<DataFrame>, org.springframework.core.serializer.Serializer<java.lang.Object>, StatefulDeserializer<DataFrame>
public class WebSocketSerializer
- extends AbstractHttpSwitchingDeserializer
- implements org.springframework.core.serializer.Serializer<java.lang.Object>
- Since:
- 3.0
- Author:
- Gary Russell
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
WebSocketSerializer
public WebSocketSerializer()
setServer
public void setServer(boolean server)
setValidateUtf8
public void setValidateUtf8(boolean validateUtf8)
- Validate UTF-8 (required for Autobahn tests).
- Parameters:
validateUtf8 -
createDataFrame
protected DataFrame createDataFrame(int type,
java.lang.String frameData)
- Overrides:
createDataFrame in class AbstractHttpSwitchingDeserializer
createState
protected AbstractHttpSwitchingDeserializer.BasicState createState()
- Overrides:
createState in class AbstractHttpSwitchingDeserializer
serialize
public void serialize(java.lang.Object frame,
java.io.OutputStream outputStream)
throws java.io.IOException
- Specified by:
serialize in interface org.springframework.core.serializer.Serializer<java.lang.Object>
- Throws:
java.io.IOException
deserialize
public DataFrame deserialize(java.io.InputStream inputStream)
throws java.io.IOException
- Specified by:
deserialize in interface org.springframework.core.serializer.Deserializer<DataFrame>- Specified by:
deserialize in class AbstractHttpSwitchingDeserializer
- Throws:
java.io.IOException
checkClosure
protected void checkClosure(int bite)
throws java.io.IOException
- Overrides:
checkClosure in class AbstractHttpSwitchingDeserializer
- Throws:
java.io.IOException
removeState
public void removeState(java.lang.Object inputStream)
- Specified by:
removeState in interface StatefulDeserializer<DataFrame>- Overrides:
removeState in class AbstractHttpSwitchingDeserializer
generateHandshake
public WebSocketFrame generateHandshake(WebSocketFrame frame)
throws java.lang.Exception
- Throws:
java.lang.Exception