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.CommandHandler.LifecycleState
ChannelHandler.Sharable
buffer, channel, clientOptions, clientResources, commandBuffer, queue, rsm, transportBuffer, writeLock
Constructor and Description |
---|
PubSubCommandHandler(ClientOptions clientOptions,
ClientResources clientResources,
Queue<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) |
activateCommandHandlerAndExecuteBufferedCommands, channelActive, channelInactive, channelRead, channelRegistered, channelUnregistered, close, exceptionCaught, flushCommands, getState, initialState, isClosed, isConnected, logPrefix, reset, setAutoFlushCommands, setRedisChannelHandler, setState, setStateIfNotClosed, 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(ClientOptions clientOptions, ClientResources clientResources, Queue<RedisCommand<K,V,?>> queue, RedisCodec<K,V> codec)
clientOptions
- client options for the connectionclientResources
- client resources for this connectionqueue
- Command queue.codec
- Codec.protected void decode(ChannelHandlerContext ctx, ByteBuf buffer) throws InterruptedException
decode
in class CommandHandler<K,V>
InterruptedException
Copyright © 2016. All rights reserved.