public class LettuceRedisPubSubConnection extends Object implements io.lettuce.core.pubsub.StatefulRedisPubSubConnection<Object,Object>
Constructor and Description |
---|
LettuceRedisPubSubConnection(GenericObjectPool connectionPool,
RedisDatabase config) |
LettuceRedisPubSubConnection(io.lettuce.core.api.StatefulRedisConnection connection,
RedisDatabase config) |
Modifier and Type | Method and Description |
---|---|
void |
addListener(io.lettuce.core.pubsub.RedisPubSubListener<Object,Object> listener) |
io.lettuce.core.pubsub.api.async.RedisPubSubAsyncCommands<Object,Object> |
async() |
void |
close() |
CompletableFuture<Void> |
closeAsync() |
static LettuceRedisPubSubConnection |
create(GenericObjectPool<io.lettuce.core.pubsub.StatefulRedisPubSubConnection> connectionPool,
RedisDatabase config) |
static LettuceRedisPubSubConnection |
create(io.lettuce.core.pubsub.StatefulRedisPubSubConnection<Object,Object> connection,
RedisDatabase config) |
Collection<io.lettuce.core.protocol.RedisCommand> |
dispatch(Collection collection) |
<T> io.lettuce.core.protocol.RedisCommand<Object,Object,T> |
dispatch(io.lettuce.core.protocol.RedisCommand<Object,Object,T> command) |
void |
flushCommands() |
C |
getDelegate() |
io.lettuce.core.ClientOptions |
getOptions() |
io.lettuce.core.resource.ClientResources |
getResources() |
Duration |
getTimeout() |
boolean |
isMulti() |
boolean |
isOpen() |
boolean |
isValid(long timeOut,
TimeUnit unit)
Pings the Redis server provided by
RedisDatabase.uri() |
io.lettuce.core.pubsub.api.reactive.RedisPubSubReactiveCommands<Object,Object> |
reactive() |
void |
removeListener(io.lettuce.core.pubsub.RedisPubSubListener<Object,Object> listener) |
void |
reset() |
void |
setAutoFlushCommands(boolean autoFlush) |
void |
setTimeout(Duration timeout) |
void |
setTimeout(long timeout,
TimeUnit unit) |
io.lettuce.core.pubsub.api.sync.RedisPubSubCommands<Object,Object> |
sync() |
public LettuceRedisPubSubConnection(GenericObjectPool connectionPool, RedisDatabase config) throws Exception
Exception
public LettuceRedisPubSubConnection(io.lettuce.core.api.StatefulRedisConnection connection, RedisDatabase config)
public static LettuceRedisPubSubConnection create(io.lettuce.core.pubsub.StatefulRedisPubSubConnection<Object,Object> connection, RedisDatabase config)
public static LettuceRedisPubSubConnection create(GenericObjectPool<io.lettuce.core.pubsub.StatefulRedisPubSubConnection> connectionPool, RedisDatabase config) throws Exception
Exception
public io.lettuce.core.pubsub.api.reactive.RedisPubSubReactiveCommands<Object,Object> reactive()
public void addListener(io.lettuce.core.pubsub.RedisPubSubListener<Object,Object> listener)
public void removeListener(io.lettuce.core.pubsub.RedisPubSubListener<Object,Object> listener)
public Collection<io.lettuce.core.protocol.RedisCommand> dispatch(Collection collection)
public io.lettuce.core.ClientOptions getOptions()
public boolean isValid(long timeOut, TimeUnit unit)
RedisDatabase.uri()
Creates a new RedisClient
based on the RedisDatabase.uri()
and sends a
BaseRedisCommands.ping()
command to verify that the server is reachable
isValid
in interface Connection
timeOut
- The time to wait for the database operation used to validate the connection to complete.unit
- time unit of timeOut
public void close() throws DatabaseException
close
in interface io.lettuce.core.api.StatefulConnection<Object,Object>
close
in interface Connection
close
in interface AutoCloseable
DatabaseException
public boolean isMulti()
public void setTimeout(Duration timeout)
public void setTimeout(long timeout, TimeUnit unit)
public Duration getTimeout()
public <T> io.lettuce.core.protocol.RedisCommand<Object,Object,T> dispatch(io.lettuce.core.protocol.RedisCommand<Object,Object,T> command)
public CompletableFuture<Void> closeAsync()
public boolean isOpen()
public io.lettuce.core.resource.ClientResources getResources()
public void reset()
public void setAutoFlushCommands(boolean autoFlush)
public void flushCommands()
public C getDelegate()
Copyright © 2020. All rights reserved.