@ChannelHandler.Sharable public class StatefulRedisSentinelConnectionImpl<K,V> extends RedisChannelHandler<K,V> implements StatefulRedisSentinelConnection<K,V>
ChannelHandler.Sharable
Modifier and Type | Field and Description |
---|---|
protected RedisSentinelAsyncCommands<K,V> |
async |
protected RedisCodec<K,V> |
codec |
protected RedisSentinelReactiveCommands<K,V> |
reactive |
protected RedisSentinelCommands<K,V> |
sync |
timeout, unit
Constructor and Description |
---|
StatefulRedisSentinelConnectionImpl(RedisChannelWriter<K,V> writer,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
RedisSentinelAsyncCommands<K,V> |
async()
Returns the
RedisSentinelAsyncCommands API for the current connection. |
<T,C extends RedisCommand<K,V,T>> |
dispatch(C cmd)
Dispatch a command.
|
RedisSentinelReactiveCommands<K,V> |
reactive()
Returns the
RedisSentinelReactiveCommands API for the current connection. |
RedisSentinelCommands<K,V> |
sync()
Returns the
RedisSentinelCommands API for the current connection. |
activated, addListener, channelRead, channelRead, channelRegistered, close, deactivated, flushCommands, getChannelWriter, getOptions, getTimeout, getTimeoutUnit, isClosed, isOpen, registerCloseables, reset, setAutoFlushCommands, setOptions, setTimeout, syncHandler
channelActive, channelInactive, channelReadComplete, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, flushCommands, getOptions, getTimeout, getTimeoutUnit, isOpen, reset, setAutoFlushCommands, setTimeout
handlerAdded, handlerRemoved
protected RedisCodec<K,V> codec
protected RedisSentinelCommands<K,V> sync
protected RedisSentinelAsyncCommands<K,V> async
protected RedisSentinelReactiveCommands<K,V> reactive
public StatefulRedisSentinelConnectionImpl(RedisChannelWriter<K,V> writer, RedisCodec<K,V> codec, long timeout, TimeUnit unit)
public <T,C extends RedisCommand<K,V,T>> C dispatch(C cmd)
StatefulConnection
dispatch
in interface StatefulConnection<K,V>
dispatch
in class RedisChannelHandler<K,V>
T
- result typeC
- command typecmd
- the Redis commandpublic RedisSentinelCommands<K,V> sync()
StatefulRedisSentinelConnection
RedisSentinelCommands
API for the current connection. Does not create a new connection.sync
in interface StatefulRedisSentinelConnection<K,V>
public RedisSentinelAsyncCommands<K,V> async()
StatefulRedisSentinelConnection
RedisSentinelAsyncCommands
API for the current connection. Does not create a new connection. *async
in interface StatefulRedisSentinelConnection<K,V>
public RedisSentinelReactiveCommands<K,V> reactive()
StatefulRedisSentinelConnection
RedisSentinelReactiveCommands
API for the current connection. Does not create a new connection. *reactive
in interface StatefulRedisSentinelConnection<K,V>
Copyright © 2016. All rights reserved.