K
- Key type.V
- Value type.@Deprecated public interface BaseRedisAsyncConnection<K,V> extends Closeable, BaseRedisAsyncCommands<K,V>
Modifier and Type | Method and Description |
---|---|
void |
close()
Deprecated.
Close the connection.
|
String |
digest(V script)
Deprecated.
Create a SHA1 digest from a Lua script.
|
RedisFuture<String> |
discard()
Deprecated.
Discard all commands issued after MULTI.
|
<T> RedisFuture<T> |
dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output)
Deprecated.
Dispatch a command to the Redis Server.
|
<T> RedisFuture<T> |
dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Deprecated.
Dispatch a command to the Redis Server.
|
RedisFuture<V> |
echo(V msg)
Deprecated.
Echo the given string.
|
RedisFuture<List<Object>> |
exec()
Deprecated.
Execute all commands issued after MULTI.
|
void |
flushCommands()
Deprecated.
Flush pending commands.
|
boolean |
isOpen()
Deprecated.
|
RedisFuture<String> |
multi()
Deprecated.
Mark the start of a transaction block.
|
RedisFuture<String> |
ping()
Deprecated.
Ping the server.
|
RedisFuture<Long> |
publish(K channel,
V message)
Deprecated.
Post a message to a channel.
|
RedisFuture<List<K>> |
pubsubChannels()
Deprecated.
Lists the currently *active channels*.
|
RedisFuture<List<K>> |
pubsubChannels(K channel)
Deprecated.
Lists the currently *active channels*.
|
RedisFuture<Long> |
pubsubNumpat()
Deprecated.
Returns the number of subscriptions to patterns.
|
RedisFuture<Map<K,Long>> |
pubsubNumsub(K... channels)
Deprecated.
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.
|
RedisFuture<String> |
quit()
Deprecated.
Close the connection.
|
RedisFuture<List<Object>> |
role()
Deprecated.
Return the role of the instance in the context of replication.
|
void |
setAutoFlushCommands(boolean autoFlush)
Deprecated.
Disable or enable auto-flush behavior.
|
RedisFuture<String> |
unwatch()
Deprecated.
Forget about all watched keys.
|
RedisFuture<Long> |
waitForReplication(int replicas,
long timeout)
Deprecated.
Wait for replication.
|
RedisFuture<String> |
watch(K... keys)
Deprecated.
Watch the given keys to determine execution of the MULTI/EXEC block.
|
readOnly, readWrite, reset
RedisFuture<Long> publish(K channel, V message)
publish
in interface BaseRedisAsyncCommands<K,V>
channel
- the channel type: keymessage
- the message type: valueRedisFuture<List<K>> pubsubChannels()
pubsubChannels
in interface BaseRedisAsyncCommands<K,V>
RedisFuture<List<K>> pubsubChannels(K channel)
pubsubChannels
in interface BaseRedisAsyncCommands<K,V>
channel
- the keyRedisFuture<Map<K,Long>> pubsubNumsub(K... channels)
pubsubNumsub
in interface BaseRedisAsyncCommands<K,V>
channels
- channel keysRedisFuture<Long> pubsubNumpat()
pubsubNumpat
in interface BaseRedisAsyncCommands<K,V>
RedisFuture<V> echo(V msg)
echo
in interface BaseRedisAsyncCommands<K,V>
msg
- the message type: valueRedisFuture<List<Object>> role()
role
in interface BaseRedisAsyncCommands<K,V>
RedisFuture<String> ping()
ping
in interface BaseRedisAsyncCommands<K,V>
RedisFuture<String> quit()
quit
in interface BaseRedisAsyncCommands<K,V>
String digest(V script)
script
- script contentRedisFuture<String> discard()
OK
.RedisFuture<List<Object>> exec()
WATCH
, EXEC
can return aRedisFuture<String> multi()
OK
.RedisFuture<String> watch(K... keys)
keys
- the keyOK
.RedisFuture<String> unwatch()
OK
.RedisFuture<Long> waitForReplication(int replicas, long timeout)
waitForReplication
in interface BaseRedisAsyncCommands<K,V>
replicas
- minimum number of replicastimeout
- timeout in milliseconds<T> RedisFuture<T> dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output)
dispatch
in interface BaseRedisAsyncCommands<K,V>
T
- response typetype
- the command, must not be null.output
- the command output, must not be null.<T> RedisFuture<T> dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
dispatch
in interface BaseRedisAsyncCommands<K,V>
T
- response typetype
- the command, must not be null.output
- the command output, must not be null.args
- the command arguments, must not be null.void close()
close
in interface AutoCloseable
close
in interface BaseRedisAsyncCommands<K,V>
close
in interface Closeable
boolean isOpen()
isOpen
in interface BaseRedisAsyncCommands<K,V>
void setAutoFlushCommands(boolean autoFlush)
flushCommands()
is
issued. After calling flushCommands()
commands are sent to the transport and executed by Redis.autoFlush
- state of autoFlush.void flushCommands()
Copyright © 2018 lettuce.io. All rights reserved.