org.msgpack.rpc.loop.netty
Class MessagePackStreamDecoder

java.lang.Object
  org.jboss.netty.channel.SimpleChannelUpstreamHandler
      org.jboss.netty.handler.codec.frame.FrameDecoder
          org.msgpack.rpc.loop.netty.MessagePackStreamDecoder

All Implemented Interfaces:

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

public class MessagePackStreamDecoder
extends org.jboss.netty.handler.codec.frame.FrameDecoder

Nested Class Summary

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

org.jboss.netty.channel.ChannelHandler.Sharable

Field Summary

protected org.msgpack.Unpacker

pac

Constructor Summary

MessagePackStreamDecoder()

Method Summary

protected java.lang.Object

decode(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.Channel channel, org.jboss.netty.buffer.ChannelBuffer source)

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

channelClosed, channelDisconnected, decodeLast, exceptionCaught, messageReceived

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

Field Detail

pac

protected org.msgpack.Unpacker pac

Constructor Detail

MessagePackStreamDecoder

public MessagePackStreamDecoder()

Method Detail

decode

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

Specified by:

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

Throws:

java.lang.Exception