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.ChannelHandler.Sharable
buffer, commandBuffer, queue, rsm
Constructor and Description |
---|
PubSubCommandHandler(BlockingQueue<RedisCommand<K,V,?>> queue,
RedisCodec<K,V> codec)
Initialize a new instance.
|
Modifier and Type | Method and Description |
---|---|
protected void |
decode(ChannelHandlerContext ctx,
ByteBuf buffer) |
channelActive, channelInactive, channelRead, channelRegistered, channelUnregistered, close, exceptionCaught, isClosed, reset, setRedisChannelHandler, write, write
bind, close, connect, deregister, disconnect, flush, read
channelReadComplete, channelWritabilityChanged, userEventTriggered
handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handlerAdded, handlerRemoved
public PubSubCommandHandler(BlockingQueue<RedisCommand<K,V,?>> queue, RedisCodec<K,V> codec)
queue
- Command queue.codec
- Codec.protected void decode(ChannelHandlerContext ctx, ByteBuf buffer) throws InterruptedException
decode
in class CommandHandler<K,V>
InterruptedException
Copyright © 2015. All rights reserved.