public class SpdyHttpDecoder extends MessageToMessageDecoder<SpdyFrame>
SpdySynStreamFrame
s, SpdySynReplyFrame
s,
and SpdyDataFrame
s into FullHttpRequest
s and FullHttpResponse
s.ChannelHandler.Sharable
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,
Map<Integer,FullHttpMessage> messageMap)
Creates a new instance with the specified parameters.
|
protected |
SpdyHttpDecoder(SpdyVersion version,
int maxContentLength,
Map<Integer,FullHttpMessage> messageMap,
boolean validateHeaders)
Creates a new instance with the specified parameters.
|
Modifier and Type | Method and Description |
---|---|
void |
channelInactive(ChannelHandlerContext ctx)
Calls
ChannelHandlerContext.fireChannelInactive() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
protected void |
decode(ChannelHandlerContext ctx,
SpdyFrame msg,
List<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, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handlerAdded, handlerRemoved
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, Map<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, Map<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 validatedpublic void channelInactive(ChannelHandlerContext ctx) throws Exception
ChannelInboundHandlerAdapter
ChannelHandlerContext.fireChannelInactive()
to forward
to the next ChannelInboundHandler
in the ChannelPipeline
.
Sub-classes may override this method to change behavior.channelInactive
in interface ChannelInboundHandler
channelInactive
in class ChannelInboundHandlerAdapter
Exception
protected FullHttpMessage putMessage(int streamId, FullHttpMessage message)
protected FullHttpMessage getMessage(int streamId)
protected FullHttpMessage removeMessage(int streamId)
protected void decode(ChannelHandlerContext ctx, SpdyFrame msg, List<Object> out) throws 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 addedException
- is thrown if an error occursCopyright © 2008–2017 The Netty Project. All rights reserved.