@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 |
---|---|
void |
activated()
Notification when the connection becomes active (connected).
|
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. |
void |
setClientName(String clientName) |
RedisSentinelCommands<K,V> |
sync()
Returns the
RedisSentinelCommands API for the current connection. |
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
ensureNotSharable, 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 final RedisCodec<K,V> codec
protected final RedisSentinelCommands<K,V> sync
protected final RedisSentinelAsyncCommands<K,V> async
protected final 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>
public void activated()
RedisChannelHandler
activated
in class RedisChannelHandler<K,V>
public void setClientName(String clientName)
Copyright © 2018 lettuce.io. All rights reserved.