com.lambdaworks.redis.pubsub

Class PubSubCommandHandler<K,V>

java.lang.Object

org.jboss.netty.channel.SimpleChannelHandler

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

com.lambdaworks.redis.pubsub.PubSubCommandHandler<K,V>

Type Parameters:

K - Key type.

V - Value type.

All Implemented Interfaces:

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

public class PubSubCommandHandler<K,V>
extends CommandHandler<K,V>

A netty ChannelHandler responsible for writing redis pub/sub commands and reading the response stream 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
private RedisCodec<K,V>	codec
private PubSubOutput<K,V>	output

Fields inherited from class com.lambdaworks.redis.protocol.CommandHandler

buffer, queue, rsm

Constructor Summary

Constructors

Constructor and Description
PubSubCommandHandler(java.util.concurrent.BlockingQueue<Command<K,V,?>> queue, RedisCodec<K,V> codec) Initialize a new instance.

Method Summary

Modifier and Type	Method and Description
protected void	decode(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.buffer.ChannelBuffer buffer)

Methods inherited from class com.lambdaworks.redis.protocol.CommandHandler

channelOpen, messageReceived, writeRequested

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

codec

private RedisCodec<K,V> codec

output

private PubSubOutput<K,V> output

Constructor Detail

PubSubCommandHandler

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

Initialize a new instance.

Parameters:

queue - Command queue.

codec - Codec.

Method Detail

decode

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

Overrides:

decode in class CommandHandler<K,V>

Throws:

java.lang.InterruptedException