public class CompatibleMarshallingDecoder extends ReplayingDecoder<java.lang.Void>
ReplayingDecoder which use an Unmarshaller to read the Object out of the ByteBuf.
If you can you should use MarshallingDecoder.ByteToMessageDecoder.Cumulator ChannelHandler.Sharable | Modifier and Type | Field and Description |
|---|---|
protected int |
maxObjectSize |
protected UnmarshallerProvider |
provider |
COMPOSITE_CUMULATOR, MERGE_CUMULATOR | Constructor and Description |
|---|
CompatibleMarshallingDecoder (UnmarshallerProvider provider,
int maxObjectSize)
Create a new instance of
CompatibleMarshallingDecoder. |
| Modifier and Type | Method and Description |
|---|---|
protected void |
decode (ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
protected void |
decodeLast (ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out)
Is called one last time when the
ChannelHandlerContext goes in-active. |
void |
exceptionCaught (ChannelHandlerContext ctx,
java.lang.Throwable cause)
Calls
ChannelHandlerContext.fireExceptionCaught(Throwable) to forward
to the next ChannelHandler in the ChannelPipeline. |
callDecode, checkpoint, checkpoint, state, state actualReadableBytes, channelInactive, channelRead, channelReadComplete, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged ensureNotSharable, handlerAdded, isSharable clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waithandlerAdded protected final UnmarshallerProvider provider
protected final int maxObjectSize
public CompatibleMarshallingDecoder(UnmarshallerProvider provider, int maxObjectSize)
CompatibleMarshallingDecoder.provider - the UnmarshallerProvider which is used to obtain the Unmarshaller
for the Channel maxObjectSize - the maximal size (in bytes) of the Object to unmarshal. Once the size is
exceeded the Channel will get closed. Use a a maxObjectSize of
Integer.MAX_VALUE to disable this. You should only do this if you are sure
that the received Objects will never be big and the sending side are trusted, as this
opens the possibility for a DOS-Attack due an OutOfMemoryError.protected void decode(ChannelHandlerContext ctx, ByteBuf buffer, java.util.List<java.lang.Object> out) throws java.lang.Exception
ByteToMessageDecoder ByteBuf to an other. This method will be called till either the input
ByteBuf has nothing to read when return from this method or till nothing was read from the input
ByteBuf.decode in class ByteToMessageDecoder ctx - the ChannelHandlerContext which this ByteToMessageDecoder belongs tobuffer - the ByteBuf from which to read dataout - the List to which decoded messages should be addedjava.lang.Exception - is thrown if an error occursprotected void decodeLast(ChannelHandlerContext ctx, ByteBuf buffer, java.util.List<java.lang.Object> out) throws java.lang.Exception
ByteToMessageDecoder ChannelHandlerContext goes in-active. Which means the
ByteToMessageDecoder.channelInactive(ChannelHandlerContext) was triggered.
By default this will just call ByteToMessageDecoder.decode(ChannelHandlerContext, ByteBuf, List) but sub-classes may
override this for some special cleanup operation.decodeLast in class ByteToMessageDecoder java.lang.Exceptionpublic void exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) throws java.lang.Exception
ChannelInboundHandlerAdapter ChannelHandlerContext.fireExceptionCaught(Throwable) to forward
to the next ChannelHandler in the ChannelPipeline.
Sub-classes may override this method to change behavior.exceptionCaught in interface ChannelHandler exceptionCaught in interface ChannelInboundHandler exceptionCaught in class ChannelInboundHandlerAdapter java.lang.ExceptionCopyright © 2008–2018 The Netty Project. All rights reserved.