K
- Key type.V
- Value type.public class PubSubCommandHandler<K,V> extends CommandHandler<K,V>
ChannelHandler
responsible for writing redis pub/sub commands
and reading the response stream from the server.buffer, queue, rsm
Constructor and Description |
---|
PubSubCommandHandler(BlockingQueue<Command<K,V,?>> queue,
RedisCodec<K,V> codec)
Initialize a new instance.
|
Modifier and Type | Method and Description |
---|---|
protected void |
decode(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.buffer.ChannelBuffer buffer) |
channelOpen, messageReceived, writeRequested
bindRequested, channelBound, channelClosed, channelConnected, channelDisconnected, channelInterestChanged, channelUnbound, childChannelClosed, childChannelOpen, closeRequested, connectRequested, disconnectRequested, exceptionCaught, handleDownstream, handleUpstream, setInterestOpsRequested, unbindRequested, writeComplete
public PubSubCommandHandler(BlockingQueue<Command<K,V,?>> queue, RedisCodec<K,V> codec)
queue
- Command queue.codec
- Codec.protected void decode(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.buffer.ChannelBuffer buffer) throws InterruptedException
decode
in class CommandHandler<K,V>
InterruptedException
Copyright © 2016. All rights reserved.