public class SpdyHttpDecoder extends MessageToMessageDecoder<SpdyFrame>
SpdySynStreamFrame
s, SpdySynReplyFrame
s,
and SpdyDataFrame
s into FullHttpRequest
s and FullHttpResponse
s.ChannelHandler.Sharable
Modifier and Type | Field and Description |
---|---|
private int |
maxContentLength |
private java.util.Map<java.lang.Integer,FullHttpMessage> |
messageMap |
private int |
spdyVersion |
private boolean |
validateHeaders |
Modifier | Constructor and Description |
---|---|
|
SpdyHttpDecoder(SpdyVersion version,
int maxContentLength)
Creates a new instance.
|
|
SpdyHttpDecoder(SpdyVersion version,
int maxContentLength,
boolean validateHeaders)
Creates a new instance.
|
protected |
SpdyHttpDecoder(SpdyVersion version,
int maxContentLength,
java.util.Map<java.lang.Integer,FullHttpMessage> messageMap)
Creates a new instance with the specified parameters.
|
protected |
SpdyHttpDecoder(SpdyVersion version,
int maxContentLength,
java.util.Map<java.lang.Integer,FullHttpMessage> messageMap,
boolean validateHeaders)
Creates a new instance with the specified parameters.
|
Modifier and Type | Method and Description |
---|---|
private static FullHttpRequest |
createHttpRequest(int spdyVersion,
SpdyHeadersFrame requestFrame) |
private static FullHttpResponse |
createHttpResponse(ChannelHandlerContext ctx,
int spdyVersion,
SpdyHeadersFrame responseFrame,
boolean validateHeaders) |
protected void |
decode(ChannelHandlerContext ctx,
SpdyFrame msg,
java.util.List<java.lang.Object> out)
Decode from one message to an other.
|
protected FullHttpMessage |
getMessage(int streamId) |
protected FullHttpMessage |
putMessage(int streamId,
FullHttpMessage message) |
protected FullHttpMessage |
removeMessage(int streamId) |
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handlerAdded, handlerRemoved
private final boolean validateHeaders
private final int spdyVersion
private final int maxContentLength
private final java.util.Map<java.lang.Integer,FullHttpMessage> messageMap
public SpdyHttpDecoder(SpdyVersion version, int maxContentLength)
version
- the protocol versionmaxContentLength
- the maximum length of the message content.
If the length of the message content exceeds this value,
a TooLongFrameException
will be raised.public SpdyHttpDecoder(SpdyVersion version, int maxContentLength, boolean validateHeaders)
version
- the protocol versionmaxContentLength
- the maximum length of the message content.
If the length of the message content exceeds this value,
a TooLongFrameException
will be raised.validateHeaders
- true
if http headers should be validatedprotected SpdyHttpDecoder(SpdyVersion version, int maxContentLength, java.util.Map<java.lang.Integer,FullHttpMessage> messageMap)
version
- the protocol versionmaxContentLength
- the maximum length of the message content.
If the length of the message content exceeds this value,
a TooLongFrameException
will be raised.messageMap
- the Map
used to hold partially received messages.protected SpdyHttpDecoder(SpdyVersion version, int maxContentLength, java.util.Map<java.lang.Integer,FullHttpMessage> messageMap, boolean validateHeaders)
version
- the protocol versionmaxContentLength
- the maximum length of the message content.
If the length of the message content exceeds this value,
a TooLongFrameException
will be raised.messageMap
- the Map
used to hold partially received messages.validateHeaders
- true
if http headers should be validatedprotected FullHttpMessage putMessage(int streamId, FullHttpMessage message)
protected FullHttpMessage getMessage(int streamId)
protected FullHttpMessage removeMessage(int streamId)
protected void decode(ChannelHandlerContext ctx, SpdyFrame msg, java.util.List<java.lang.Object> out) throws java.lang.Exception
MessageToMessageDecoder
decode
in class MessageToMessageDecoder<SpdyFrame>
ctx
- the ChannelHandlerContext
which this MessageToMessageDecoder
belongs tomsg
- the message to decode to an other oneout
- the List
to which decoded messages should be addedjava.lang.Exception
- is thrown if an error accourprivate static FullHttpRequest createHttpRequest(int spdyVersion, SpdyHeadersFrame requestFrame) throws java.lang.Exception
java.lang.Exception
private static FullHttpResponse createHttpResponse(ChannelHandlerContext ctx, int spdyVersion, SpdyHeadersFrame responseFrame, boolean validateHeaders) throws java.lang.Exception
java.lang.Exception