org.apache.avro.ipc

Class NettyTransportCodec.NettyFrameDecoder

java.lang.Object

org.jboss.netty.channel.SimpleChannelUpstreamHandler

org.jboss.netty.handler.codec.frame.FrameDecoder

org.apache.avro.ipc.NettyTransportCodec.NettyFrameDecoder

All Implemented Interfaces:

org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler

Enclosing class:

NettyTransportCodec

public static class NettyTransportCodec.NettyFrameDecoder
extends org.jboss.netty.handler.codec.frame.FrameDecoder

Protocol decoder which converts Netty's ChannelBuffer to NettyDataPack which contains a List<ByteBuffer> needed by Avro Responder.

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler

org.jboss.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
NettyTransportCodec.NettyFrameDecoder()

Method Summary

Methods

Modifier and Type	Method and Description
protected Object	decode(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.Channel channel, org.jboss.netty.buffer.ChannelBuffer buffer) decode buffer to NettyDataPack

Methods inherited from class org.jboss.netty.handler.codec.frame.FrameDecoder

channelClosed, channelDisconnected, decodeLast, exceptionCaught, messageReceived, newCumulationBuffer

Methods inherited from class org.jboss.netty.channel.SimpleChannelUpstreamHandler

channelBound, channelConnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, handleUpstream, writeComplete

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NettyTransportCodec.NettyFrameDecoder

public NettyTransportCodec.NettyFrameDecoder()

Method Detail

decode

protected Object decode(org.jboss.netty.channel.ChannelHandlerContext ctx,
            org.jboss.netty.channel.Channel channel,
            org.jboss.netty.buffer.ChannelBuffer buffer)
                 throws Exception

decode buffer to NettyDataPack

Specified by:

decode in class org.jboss.netty.handler.codec.frame.FrameDecoder

Throws:

Exception