com.lambdaworks.redis.protocol

Class CommandHandler<K,V>

java.lang.Object

org.jboss.netty.channel.SimpleChannelHandler

com.lambdaworks.redis.protocol.CommandHandler<K,V>

All Implemented Interfaces:

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

Direct Known Subclasses:

PubSubCommandHandler

public class CommandHandler<K,V>
extends org.jboss.netty.channel.SimpleChannelHandler

A netty ChannelHandler responsible for writing redis commands and reading responses from the server.

Nested Class Summary

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

org.jboss.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
protected org.jboss.netty.buffer.ChannelBuffer	buffer
protected java.util.concurrent.BlockingQueue<Command<K,V,?>>	queue
protected RedisStateMachine<K,V>	rsm

Constructor Summary

Constructors

Constructor and Description
CommandHandler(java.util.concurrent.BlockingQueue<Command<K,V,?>> queue) Initialize a new instance that handles commands from the supplied queue.

Method Summary

Modifier and Type	Method and Description
void	channelOpen(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e)
protected void	decode(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.buffer.ChannelBuffer buffer)
void	messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent e)
void	writeRequested(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent e)

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

bindRequested, channelBound, channelClosed, channelConnected, channelDisconnected, channelInterestChanged, channelUnbound, childChannelClosed, childChannelOpen, closeRequested, connectRequested, disconnectRequested, exceptionCaught, handleDownstream, handleUpstream, setInterestOpsRequested, unbindRequested, writeComplete

Methods inherited from class java.lang.Object

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

Field Detail

queue

protected java.util.concurrent.BlockingQueue<Command<K,V,?>> queue

buffer

protected org.jboss.netty.buffer.ChannelBuffer buffer

rsm

protected RedisStateMachine<K,V> rsm

Constructor Detail

CommandHandler

public CommandHandler(java.util.concurrent.BlockingQueue<Command<K,V,?>> queue)

Initialize a new instance that handles commands from the supplied queue.

Parameters:

queue - The command queue.

Method Detail

channelOpen

public void channelOpen(org.jboss.netty.channel.ChannelHandlerContext ctx,
                        org.jboss.netty.channel.ChannelStateEvent e)
                 throws java.lang.Exception

Overrides:

channelOpen in class org.jboss.netty.channel.SimpleChannelHandler

Throws:

java.lang.Exception

writeRequested

public void writeRequested(org.jboss.netty.channel.ChannelHandlerContext ctx,
                           org.jboss.netty.channel.MessageEvent e)
                    throws java.lang.Exception

Overrides:

writeRequested in class org.jboss.netty.channel.SimpleChannelHandler

Throws:

java.lang.Exception

messageReceived

public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
                            org.jboss.netty.channel.MessageEvent e)
                     throws java.lang.Exception

Overrides:

messageReceived in class org.jboss.netty.channel.SimpleChannelHandler

Throws:

java.lang.Exception

decode

protected void decode(org.jboss.netty.channel.ChannelHandlerContext ctx,
                      org.jboss.netty.buffer.ChannelBuffer buffer)
               throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException