org.openspaces.memcached.protocol.text

Class MemcachedCommandDecoder

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.openspaces.memcached.protocol.text.MemcachedCommandDecoder

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

public final class MemcachedCommandDecoder
extends io.netty.channel.ChannelInboundHandlerAdapter

The MemcachedCommandDecoder is responsible for taking lines from the MemcachedFrameDecoder and parsing them into CommandMessage instances for handling by the MemcachedCommandHandler

Protocol status is held in the SessionStatus instance which is shared between each of the decoders in the pipeline.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
MemcachedCommandDecoder(SessionStatus status)

Method Summary

Modifier and Type	Method and Description
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg) Process an inbound string from the pipeline's downstream, and depending on the state (waiting for data or processing commands), turn them into the correct type of command.

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

MemcachedCommandDecoder

public MemcachedCommandDecoder(SessionStatus status)

Method Detail

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        Object msg)
                 throws Exception

Process an inbound string from the pipeline's downstream, and depending on the state (waiting for data or processing commands), turn them into the correct type of command.

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

Parameters:

ctx - netty channel handler context

msg - the netty event that corresponds to the message

Throws:

Exception