Spring Integration IP Extensions

org.springframework.integration.x.ip.websocket
Class WebSocketSerializer

java.lang.Object
  extended by org.springframework.integration.x.ip.serializer.AbstractHttpSwitchingDeserializer
      extended by 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

Nested Class Summary
static class WebSocketSerializer.WebSocketState
           
 
Nested classes/interfaces inherited from class org.springframework.integration.x.ip.serializer.AbstractHttpSwitchingDeserializer
AbstractHttpSwitchingDeserializer.BasicState
 
Field Summary
 
Fields inherited from class org.springframework.integration.x.ip.serializer.AbstractHttpSwitchingDeserializer
crlfDeserializer, logger, maxMessageSize
 
Constructor Summary
WebSocketSerializer()
           
 
Method Summary
protected  void checkClosure(int bite)
           
protected  DataFrame createDataFrame(int type, java.lang.String frameData)
           
protected  AbstractHttpSwitchingDeserializer.BasicState createState()
           
 DataFrame deserialize(java.io.InputStream inputStream)
           
 WebSocketFrame generateHandshake(WebSocketFrame frame)
           
 void removeState(java.lang.Object inputStream)
           
 void serialize(java.lang.Object frame, java.io.OutputStream outputStream)
           
 void setServer(boolean server)
           
 void setValidateUtf8(boolean validateUtf8)
          Validate UTF-8 (required for Autobahn tests).
 
Methods inherited from class org.springframework.integration.x.ip.serializer.AbstractHttpSwitchingDeserializer
checkStreaming, decodeHeaders, getCrlfDeserializer, getState, getStreamState, setMaxMessageSize
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

WebSocketSerializer

public WebSocketSerializer()
Method Detail

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

Spring Integration IP Extensions