RedisAsyncConnection

java.lang.Object
- org.jboss.netty.channel.SimpleChannelUpstreamHandler
- - com.lambdaworks.redis.RedisAsyncConnection<K,V>

All Implemented Interfaces:

org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler

Direct Known Subclasses:

RedisPubSubConnection
```
public class RedisAsyncConnection<K,V>
extends org.jboss.netty.channel.SimpleChannelUpstreamHandler
```
An asynchronous thread-safe connection to a redis server. Multiple threads may share one RedisAsyncConnection provided they avoid blocking and transactional operations such as blpop(long, K...) and multi()/exec(). A ConnectionWatchdog monitors each connection and reconnects automatically until close() is called. All pending commands will be (re)sent after successful reconnection.

Nested Class Summary
- Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler
  org.jboss.netty.channel.ChannelHandler.Sharable

Field Summary

Fields
Modifier and Type	Field and Description
`protected org.jboss.netty.channel.Channel`	`channel`
`private boolean`	`closed`
`protected RedisCodec<K,V>`	`codec`
`private int`	`db`
`protected MultiOutput<K,V>`	`multi`
`private java.lang.String`	`password`
`protected java.util.concurrent.BlockingQueue<Command<K,V,?>>`	`queue`
`protected long`	`timeout`
`protected java.util.concurrent.TimeUnit`	`unit`

Constructor Summary

Constructors
Constructor and Description
`RedisAsyncConnection(java.util.concurrent.BlockingQueue<Command<K,V,?>> queue, RedisCodec<K,V> codec, long timeout, java.util.concurrent.TimeUnit unit)` Initialize a new connection.

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method and Description
`java.util.concurrent.Future<java.lang.Long>`	`append(K key, V value)`
`java.lang.String`	`auth(java.lang.String password)`
`<T> T`	`await(Command<K,V,T> cmd, long timeout, java.util.concurrent.TimeUnit unit)`
`boolean`	`awaitAll(java.util.concurrent.Future<?>... futures)` Wait until commands are complete or the connection timeout is reached.
`boolean`	`awaitAll(long timeout, java.util.concurrent.TimeUnit unit, java.util.concurrent.Future<?>... futures)` Wait until futures are complete or the supplied timeout is reached.
`java.util.concurrent.Future<java.lang.String>`	`bgrewriteaof()`
`java.util.concurrent.Future<java.lang.String>`	`bgsave()`
`java.util.concurrent.Future<java.lang.Long>`	`bitcount(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`bitcount(K key, long start, long end)`
`java.util.concurrent.Future<java.lang.Long>`	`bitopAnd(K destination, K... keys)`
`java.util.concurrent.Future<java.lang.Long>`	`bitopNot(K destination, K source)`
`java.util.concurrent.Future<java.lang.Long>`	`bitopOr(K destination, K... keys)`
`java.util.concurrent.Future<java.lang.Long>`	`bitopXor(K destination, K... keys)`
`java.util.concurrent.Future<KeyValue<K,V>>`	`blpop(long timeout, K... keys)`
`java.util.concurrent.Future<KeyValue<K,V>>`	`brpop(long timeout, K... keys)`
`java.util.concurrent.Future<V>`	`brpoplpush(long timeout, K source, K destination)`
`void`	`channelClosed(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e)`
`void`	`channelConnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e)`
`java.util.concurrent.Future<K>`	`clientGetname()`
`java.util.concurrent.Future<java.lang.String>`	`clientKill(java.lang.String addr)`
`java.util.concurrent.Future<java.lang.String>`	`clientList()`
`java.util.concurrent.Future<java.lang.String>`	`clientSetname(K name)`
`void`	`close()` Close the connection.
`java.util.concurrent.Future<java.util.List<java.lang.String>>`	`configGet(java.lang.String parameter)`
`java.util.concurrent.Future<java.lang.String>`	`configResetstat()`
`java.util.concurrent.Future<java.lang.String>`	`configSet(java.lang.String parameter, java.lang.String value)`
`java.util.concurrent.Future<java.lang.Long>`	`dbsize()`
`java.util.concurrent.Future<java.lang.String>`	`debugObject(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`decr(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`decrby(K key, long amount)`
`java.util.concurrent.Future<java.lang.Long>`	`del(K... keys)`
`java.lang.String`	`digest(V script)`
`java.util.concurrent.Future<java.lang.String>`	`discard()`
`<T> Command<K,V,T>`	`dispatch(CommandType type, CommandOutput<K,V,T> output)`
`<T> Command<K,V,T>`	`dispatch(CommandType type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)`
`<T> Command<K,V,T>`	`dispatch(CommandType type, CommandOutput<K,V,T> output, K key)`
`<T> Command<K,V,T>`	`dispatch(CommandType type, CommandOutput<K,V,T> output, K key, V value)`
`<T> Command<K,V,T>`	`dispatch(CommandType type, CommandOutput<K,V,T> output, K key, V[] values)`
`java.util.concurrent.Future<byte[]>`	`dump(K key)`
`java.util.concurrent.Future<V>`	`echo(V msg)`
`<T> java.util.concurrent.Future<T>`	`eval(V script, ScriptOutputType type, K[] keys, V... values)`
`<T> java.util.concurrent.Future<T>`	`evalsha(java.lang.String digest, ScriptOutputType type, K[] keys, V... values)`
`java.util.concurrent.Future<java.util.List<java.lang.Object>>`	`exec()`
`java.util.concurrent.Future<java.lang.Boolean>`	`exists(K key)`
`java.util.concurrent.Future<java.lang.Boolean>`	`expire(K key, long seconds)`
`java.util.concurrent.Future<java.lang.Boolean>`	`expireat(K key, java.util.Date timestamp)`
`java.util.concurrent.Future<java.lang.Boolean>`	`expireat(K key, long timestamp)`
`java.util.concurrent.Future<java.lang.String>`	`flushall()`
`java.util.concurrent.Future<java.lang.String>`	`flushdb()`
`java.util.concurrent.Future<V>`	`get(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`getbit(K key, long offset)`
`java.util.concurrent.Future<V>`	`getrange(K key, long start, long end)`
`java.util.concurrent.Future<V>`	`getset(K key, V value)`
`java.util.concurrent.Future<java.lang.Long>`	`hdel(K key, K... fields)`
`java.util.concurrent.Future<java.lang.Boolean>`	`hexists(K key, K field)`
`java.util.concurrent.Future<V>`	`hget(K key, K field)`
`java.util.concurrent.Future<java.util.Map<K,V>>`	`hgetall(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`hincrby(K key, K field, long amount)`
`java.util.concurrent.Future<java.lang.Double>`	`hincrbyfloat(K key, K field, double amount)`
`java.util.concurrent.Future<java.util.List<K>>`	`hkeys(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`hlen(K key)`
`java.util.concurrent.Future<java.util.List<V>>`	`hmget(K key, K... fields)`
`java.util.concurrent.Future<java.lang.String>`	`hmset(K key, java.util.Map<K,V> map)`
`java.util.concurrent.Future<java.lang.Boolean>`	`hset(K key, K field, V value)`
`java.util.concurrent.Future<java.lang.Boolean>`	`hsetnx(K key, K field, V value)`
`java.util.concurrent.Future<java.util.List<V>>`	`hvals(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`incr(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`incrby(K key, long amount)`
`java.util.concurrent.Future<java.lang.Double>`	`incrbyfloat(K key, double amount)`
`java.util.concurrent.Future<java.lang.String>`	`info()`
`java.util.concurrent.Future<java.lang.String>`	`info(java.lang.String section)`
`java.util.concurrent.Future<java.util.List<K>>`	`keys(K pattern)`
`java.util.concurrent.Future<java.util.Date>`	`lastsave()`
`java.util.concurrent.Future<V>`	`lindex(K key, long index)`
`java.util.concurrent.Future<java.lang.Long>`	`linsert(K key, boolean before, V pivot, V value)`
`java.util.concurrent.Future<java.lang.Long>`	`llen(K key)`
`java.util.concurrent.Future<V>`	`lpop(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`lpush(K key, V... values)`
`java.util.concurrent.Future<java.lang.Long>`	`lpushx(K key, V value)`
`java.util.concurrent.Future<java.util.List<V>>`	`lrange(K key, long start, long stop)`
`java.util.concurrent.Future<java.lang.Long>`	`lrem(K key, long count, V value)`
`java.util.concurrent.Future<java.lang.String>`	`lset(K key, long index, V value)`
`java.util.concurrent.Future<java.lang.String>`	`ltrim(K key, long start, long stop)`
`java.util.concurrent.Future<java.util.List<V>>`	`mget(K... keys)`
`java.util.concurrent.Future<java.lang.String>`	`migrate(java.lang.String host, int port, K key, int db, long timeout)`
`java.util.concurrent.Future<java.lang.Boolean>`	`move(K key, int db)`
`java.util.concurrent.Future<java.lang.String>`	`mset(java.util.Map<K,V> map)`
`java.util.concurrent.Future<java.lang.Boolean>`	`msetnx(java.util.Map<K,V> map)`
`java.util.concurrent.Future<java.lang.String>`	`multi()`
`protected <K,V,T> CommandOutput<K,V,T>`	`newScriptOutput(RedisCodec<K,V> codec, ScriptOutputType type)`
`java.util.concurrent.Future<java.lang.String>`	`objectEncoding(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`objectIdletime(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`objectRefcount(K key)`
`java.util.concurrent.Future<java.lang.Boolean>`	`persist(K key)`
`java.util.concurrent.Future<java.lang.Boolean>`	`pexpire(K key, long milliseconds)`
`java.util.concurrent.Future<java.lang.Boolean>`	`pexpireat(K key, java.util.Date timestamp)`
`java.util.concurrent.Future<java.lang.Boolean>`	`pexpireat(K key, long timestamp)`
`java.util.concurrent.Future<java.lang.String>`	`ping()`
`java.util.concurrent.Future<java.lang.Long>`	`pttl(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`publish(K channel, V message)`
`java.util.concurrent.Future<java.lang.String>`	`quit()`
`java.util.concurrent.Future<V>`	`randomkey()`
`java.util.concurrent.Future<java.lang.String>`	`rename(K key, K newKey)`
`java.util.concurrent.Future<java.lang.Boolean>`	`renamenx(K key, K newKey)`
`java.util.concurrent.Future<java.lang.String>`	`restore(K key, long ttl, byte[] value)`
`java.util.concurrent.Future<V>`	`rpop(K key)`
`java.util.concurrent.Future<V>`	`rpoplpush(K source, K destination)`
`java.util.concurrent.Future<java.lang.Long>`	`rpush(K key, V... values)`
`java.util.concurrent.Future<java.lang.Long>`	`rpushx(K key, V value)`
`java.util.concurrent.Future<java.lang.Long>`	`sadd(K key, V... members)`
`java.util.concurrent.Future<java.lang.String>`	`save()`
`java.util.concurrent.Future<java.lang.Long>`	`scard(K key)`
`java.util.concurrent.Future<java.util.List<java.lang.Boolean>>`	`scriptExists(java.lang.String... digests)`
`java.util.concurrent.Future<java.lang.String>`	`scriptFlush()`
`java.util.concurrent.Future<java.lang.String>`	`scriptKill()`
`java.util.concurrent.Future<java.lang.String>`	`scriptLoad(V script)`
`java.util.concurrent.Future<java.util.Set<V>>`	`sdiff(K... keys)`
`java.util.concurrent.Future<java.lang.Long>`	`sdiffstore(K destination, K... keys)`
`java.lang.String`	`select(int db)`
`java.util.concurrent.Future<java.lang.String>`	`set(K key, V value)`
`java.util.concurrent.Future<java.lang.Long>`	`setbit(K key, long offset, int value)`
`java.util.concurrent.Future<java.lang.String>`	`setex(K key, long seconds, V value)`
`java.util.concurrent.Future<java.lang.Boolean>`	`setnx(K key, V value)`
`java.util.concurrent.Future<java.lang.Long>`	`setrange(K key, long offset, V value)`
`void`	`setTimeout(long timeout, java.util.concurrent.TimeUnit unit)` Set the command timeout for this connection.
`void`	`shutdown()` Deprecated.
`void`	`shutdown(boolean save)`
`java.util.concurrent.Future<java.util.Set<V>>`	`sinter(K... keys)`
`java.util.concurrent.Future<java.lang.Long>`	`sinterstore(K destination, K... keys)`
`java.util.concurrent.Future<java.lang.Boolean>`	`sismember(K key, V member)`
`java.util.concurrent.Future<java.lang.String>`	`slaveof(java.lang.String host, int port)`
`java.util.concurrent.Future<java.lang.String>`	`slaveofNoOne()`
`java.util.concurrent.Future<java.util.List<java.lang.Object>>`	`slowlogGet()`
`java.util.concurrent.Future<java.util.List<java.lang.Object>>`	`slowlogGet(int count)`
`java.util.concurrent.Future<java.lang.Long>`	`slowlogLen()`
`java.util.concurrent.Future<java.lang.String>`	`slowlogReset()`
`java.util.concurrent.Future<java.util.Set<V>>`	`smembers(K key)`
`java.util.concurrent.Future<java.lang.Boolean>`	`smove(K source, K destination, V member)`
`java.util.concurrent.Future<java.util.List<V>>`	`sort(K key)`
`java.util.concurrent.Future<java.util.List<V>>`	`sort(K key, SortArgs sortArgs)`
`java.util.concurrent.Future<java.lang.Long>`	`sortStore(K key, SortArgs sortArgs, K destination)`
`java.util.concurrent.Future<V>`	`spop(K key)`
`java.util.concurrent.Future<V>`	`srandmember(K key)`
`java.util.concurrent.Future<java.util.Set<V>>`	`srandmember(K key, long count)`
`java.util.concurrent.Future<java.lang.Long>`	`srem(K key, V... members)`
`java.lang.String`	`string(double n)`
`java.util.concurrent.Future<java.lang.Long>`	`strlen(K key)`
`java.util.concurrent.Future<java.util.Set<V>>`	`sunion(K... keys)`
`java.util.concurrent.Future<java.lang.Long>`	`sunionstore(K destination, K... keys)`
`java.util.concurrent.Future<java.lang.String>`	`sync()`
`java.util.concurrent.Future<java.lang.Long>`	`ttl(K key)`
`java.util.concurrent.Future<java.lang.String>`	`type(K key)`
`java.util.concurrent.Future<java.lang.String>`	`unwatch()`
`java.util.concurrent.Future<java.lang.String>`	`watch(K... keys)`
`java.util.concurrent.Future<java.lang.Long>`	`zadd(K key, double score, V member)`
`java.util.concurrent.Future<java.lang.Long>`	`zadd(K key, java.lang.Object... scoresAndValues)`
`java.util.concurrent.Future<java.lang.Long>`	`zcard(K key)`
`java.util.concurrent.Future<java.lang.Long>`	`zcount(K key, double min, double max)`
`java.util.concurrent.Future<java.lang.Long>`	`zcount(K key, java.lang.String min, java.lang.String max)`
`java.util.concurrent.Future<java.lang.Double>`	`zincrby(K key, double amount, K member)`
`java.util.concurrent.Future<java.lang.Long>`	`zinterstore(K destination, K... keys)`
`java.util.concurrent.Future<java.lang.Long>`	`zinterstore(K destination, ZStoreArgs storeArgs, K... keys)`
`java.util.concurrent.Future<java.util.List<V>>`	`zrange(K key, long start, long stop)`
`java.util.concurrent.Future<java.util.List<V>>`	`zrangebyscore(K key, double min, double max)`
`java.util.concurrent.Future<java.util.List<V>>`	`zrangebyscore(K key, double min, double max, long offset, long count)`
`java.util.concurrent.Future<java.util.List<V>>`	`zrangebyscore(K key, java.lang.String min, java.lang.String max)`
`java.util.concurrent.Future<java.util.List<V>>`	`zrangebyscore(K key, java.lang.String min, java.lang.String max, long offset, long count)`
`java.util.concurrent.Future<java.util.List<ScoredValue<V>>>`	`zrangebyscoreWithScores(K key, double min, double max)`
`java.util.concurrent.Future<java.util.List<ScoredValue<V>>>`	`zrangebyscoreWithScores(K key, double min, double max, long offset, long count)`
`java.util.concurrent.Future<java.util.List<ScoredValue<V>>>`	`zrangebyscoreWithScores(K key, java.lang.String min, java.lang.String max)`
`java.util.concurrent.Future<java.util.List<ScoredValue<V>>>`	`zrangebyscoreWithScores(K key, java.lang.String min, java.lang.String max, long offset, long count)`
`java.util.concurrent.Future<java.util.List<ScoredValue<V>>>`	`zrangeWithScores(K key, long start, long stop)`
`java.util.concurrent.Future<java.lang.Long>`	`zrank(K key, V member)`
`java.util.concurrent.Future<java.lang.Long>`	`zrem(K key, V... members)`
`java.util.concurrent.Future<java.lang.Long>`	`zremrangebyrank(K key, long start, long stop)`
`java.util.concurrent.Future<java.lang.Long>`	`zremrangebyscore(K key, double min, double max)`
`java.util.concurrent.Future<java.lang.Long>`	`zremrangebyscore(K key, java.lang.String min, java.lang.String max)`
`java.util.concurrent.Future<java.util.List<V>>`	`zrevrange(K key, long start, long stop)`
`java.util.concurrent.Future<java.util.List<V>>`	`zrevrangebyscore(K key, double max, double min)`
`java.util.concurrent.Future<java.util.List<V>>`	`zrevrangebyscore(K key, double max, double min, long offset, long count)`
`java.util.concurrent.Future<java.util.List<V>>`	`zrevrangebyscore(K key, java.lang.String max, java.lang.String min)`
`java.util.concurrent.Future<java.util.List<V>>`	`zrevrangebyscore(K key, java.lang.String max, java.lang.String min, long offset, long count)`
`java.util.concurrent.Future<java.util.List<ScoredValue<V>>>`	`zrevrangebyscoreWithScores(K key, double max, double min)`
`java.util.concurrent.Future<java.util.List<ScoredValue<V>>>`	`zrevrangebyscoreWithScores(K key, double max, double min, long offset, long count)`
`java.util.concurrent.Future<java.util.List<ScoredValue<V>>>`	`zrevrangebyscoreWithScores(K key, java.lang.String max, java.lang.String min)`
`java.util.concurrent.Future<java.util.List<ScoredValue<V>>>`	`zrevrangebyscoreWithScores(K key, java.lang.String max, java.lang.String min, long offset, long count)`
`java.util.concurrent.Future<java.util.List<ScoredValue<V>>>`	`zrevrangeWithScores(K key, long start, long stop)`
`java.util.concurrent.Future<java.lang.Long>`	`zrevrank(K key, V member)`
`java.util.concurrent.Future<java.lang.Double>`	`zscore(K key, V member)`
`java.util.concurrent.Future<java.lang.Long>`	`zunionstore(K destination, K... keys)`
`java.util.concurrent.Future<java.lang.Long>`	`zunionstore(K destination, ZStoreArgs storeArgs, K... keys)`

Methods inherited from class org.jboss.netty.channel.SimpleChannelUpstreamHandler
channelBound, channelDisconnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, exceptionCaught, handleUpstream, messageReceived, writeComplete

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

queue

protected java.util.concurrent.BlockingQueue<Command<K,V,?>> queue

codec
```
protected RedisCodec<K,V> codec
```

channel

protected org.jboss.netty.channel.Channel channel

timeout
```
protected long timeout
```

unit

protected java.util.concurrent.TimeUnit unit

multi
```
protected MultiOutput<K,V> multi
```

password
```
private java.lang.String password
```

db
```
private int db
```

closed
```
private boolean closed
```

Constructor Detail

RedisAsyncConnection

public RedisAsyncConnection(java.util.concurrent.BlockingQueue<Command<K,V,?>> queue,
                            RedisCodec<K,V> codec,
                            long timeout,
                            java.util.concurrent.TimeUnit unit)

Initialize a new connection.

Parameters:: queue - Command queue.; codec - Codec used to encode/decode keys and values.; timeout - Maximum time to wait for a response.; unit - Unit of time for the timeout.

Method Detail

setTimeout
```
public void setTimeout(long timeout,
                       java.util.concurrent.TimeUnit unit)
```
Set the command timeout for this connection.

Parameters:

timeout - Command timeout.

unit - Unit of time for the timeout.

append

public java.util.concurrent.Future<java.lang.Long> append(K key,
                                                          V value)

auth

public java.lang.String auth(java.lang.String password)

bgrewriteaof

public java.util.concurrent.Future<java.lang.String> bgrewriteaof()

bgsave

public java.util.concurrent.Future<java.lang.String> bgsave()

bitcount

public java.util.concurrent.Future<java.lang.Long> bitcount(K key)

bitcount

public java.util.concurrent.Future<java.lang.Long> bitcount(K key,
                                                            long start,
                                                            long end)

bitopAnd

public java.util.concurrent.Future<java.lang.Long> bitopAnd(K destination,
                                                            K... keys)

bitopNot

public java.util.concurrent.Future<java.lang.Long> bitopNot(K destination,
                                                            K source)

bitopOr

public java.util.concurrent.Future<java.lang.Long> bitopOr(K destination,
                                                           K... keys)

bitopXor

public java.util.concurrent.Future<java.lang.Long> bitopXor(K destination,
                                                            K... keys)

blpop

public java.util.concurrent.Future<KeyValue<K,V>> blpop(long timeout,
                                                        K... keys)

brpop

public java.util.concurrent.Future<KeyValue<K,V>> brpop(long timeout,
                                                        K... keys)

brpoplpush

public java.util.concurrent.Future<V> brpoplpush(long timeout,
                                                 K source,
                                                 K destination)

clientGetname

public java.util.concurrent.Future<K> clientGetname()

clientSetname

public java.util.concurrent.Future<java.lang.String> clientSetname(K name)

clientKill

public java.util.concurrent.Future<java.lang.String> clientKill(java.lang.String addr)

clientList

public java.util.concurrent.Future<java.lang.String> clientList()

configGet

public java.util.concurrent.Future<java.util.List<java.lang.String>> configGet(java.lang.String parameter)

configResetstat

public java.util.concurrent.Future<java.lang.String> configResetstat()

configSet

public java.util.concurrent.Future<java.lang.String> configSet(java.lang.String parameter,
                                                               java.lang.String value)

dbsize

public java.util.concurrent.Future<java.lang.Long> dbsize()

debugObject

public java.util.concurrent.Future<java.lang.String> debugObject(K key)

decr

public java.util.concurrent.Future<java.lang.Long> decr(K key)

decrby

public java.util.concurrent.Future<java.lang.Long> decrby(K key,
                                                          long amount)

del

public java.util.concurrent.Future<java.lang.Long> del(K... keys)

discard

public java.util.concurrent.Future<java.lang.String> discard()

dump

public java.util.concurrent.Future<byte[]> dump(K key)

echo

public java.util.concurrent.Future<V> echo(V msg)

eval

public <T> java.util.concurrent.Future<T> eval(V script,
                                               ScriptOutputType type,
                                               K[] keys,
                                               V... values)

evalsha

public <T> java.util.concurrent.Future<T> evalsha(java.lang.String digest,
                                                  ScriptOutputType type,
                                                  K[] keys,
                                                  V... values)

exists

public java.util.concurrent.Future<java.lang.Boolean> exists(K key)

expire

public java.util.concurrent.Future<java.lang.Boolean> expire(K key,
                                                             long seconds)

expireat

public java.util.concurrent.Future<java.lang.Boolean> expireat(K key,
                                                               java.util.Date timestamp)

expireat

public java.util.concurrent.Future<java.lang.Boolean> expireat(K key,
                                                               long timestamp)

exec

public java.util.concurrent.Future<java.util.List<java.lang.Object>> exec()

flushall

public java.util.concurrent.Future<java.lang.String> flushall()
                                                       throws java.lang.Exception

Throws:: java.lang.Exception

flushdb

public java.util.concurrent.Future<java.lang.String> flushdb()
                                                      throws java.lang.Exception

Throws:: java.lang.Exception

get

public java.util.concurrent.Future<V> get(K key)

getbit

public java.util.concurrent.Future<java.lang.Long> getbit(K key,
                                                          long offset)

getrange

public java.util.concurrent.Future<V> getrange(K key,
                                               long start,
                                               long end)

getset

public java.util.concurrent.Future<V> getset(K key,
                                             V value)

hdel

public java.util.concurrent.Future<java.lang.Long> hdel(K key,
                                                        K... fields)

hexists

public java.util.concurrent.Future<java.lang.Boolean> hexists(K key,
                                                              K field)

hget

public java.util.concurrent.Future<V> hget(K key,
                                           K field)

hincrby

public java.util.concurrent.Future<java.lang.Long> hincrby(K key,
                                                           K field,
                                                           long amount)

hincrbyfloat

public java.util.concurrent.Future<java.lang.Double> hincrbyfloat(K key,
                                                                  K field,
                                                                  double amount)

hgetall

public java.util.concurrent.Future<java.util.Map<K,V>> hgetall(K key)

hkeys

public java.util.concurrent.Future<java.util.List<K>> hkeys(K key)

hlen

public java.util.concurrent.Future<java.lang.Long> hlen(K key)

hmget

public java.util.concurrent.Future<java.util.List<V>> hmget(K key,
                                                            K... fields)

hmset

public java.util.concurrent.Future<java.lang.String> hmset(K key,
                                                           java.util.Map<K,V> map)

hset

public java.util.concurrent.Future<java.lang.Boolean> hset(K key,
                                                           K field,
                                                           V value)

hsetnx

public java.util.concurrent.Future<java.lang.Boolean> hsetnx(K key,
                                                             K field,
                                                             V value)

hvals

public java.util.concurrent.Future<java.util.List<V>> hvals(K key)

incr

public java.util.concurrent.Future<java.lang.Long> incr(K key)

incrby

public java.util.concurrent.Future<java.lang.Long> incrby(K key,
                                                          long amount)

incrbyfloat

public java.util.concurrent.Future<java.lang.Double> incrbyfloat(K key,
                                                                 double amount)

info

public java.util.concurrent.Future<java.lang.String> info()

info

public java.util.concurrent.Future<java.lang.String> info(java.lang.String section)

keys

public java.util.concurrent.Future<java.util.List<K>> keys(K pattern)

lastsave

public java.util.concurrent.Future<java.util.Date> lastsave()

lindex

public java.util.concurrent.Future<V> lindex(K key,
                                             long index)

linsert

public java.util.concurrent.Future<java.lang.Long> linsert(K key,
                                                           boolean before,
                                                           V pivot,
                                                           V value)

llen

public java.util.concurrent.Future<java.lang.Long> llen(K key)

lpop

public java.util.concurrent.Future<V> lpop(K key)

lpush

public java.util.concurrent.Future<java.lang.Long> lpush(K key,
                                                         V... values)

lpushx

public java.util.concurrent.Future<java.lang.Long> lpushx(K key,
                                                          V value)

lrange

public java.util.concurrent.Future<java.util.List<V>> lrange(K key,
                                                             long start,
                                                             long stop)

lrem

public java.util.concurrent.Future<java.lang.Long> lrem(K key,
                                                        long count,
                                                        V value)

lset

public java.util.concurrent.Future<java.lang.String> lset(K key,
                                                          long index,
                                                          V value)

ltrim

public java.util.concurrent.Future<java.lang.String> ltrim(K key,
                                                           long start,
                                                           long stop)

migrate

public java.util.concurrent.Future<java.lang.String> migrate(java.lang.String host,
                                                             int port,
                                                             K key,
                                                             int db,
                                                             long timeout)

mget

public java.util.concurrent.Future<java.util.List<V>> mget(K... keys)

move

public java.util.concurrent.Future<java.lang.Boolean> move(K key,
                                                           int db)

multi

public java.util.concurrent.Future<java.lang.String> multi()

mset

public java.util.concurrent.Future<java.lang.String> mset(java.util.Map<K,V> map)

msetnx

public java.util.concurrent.Future<java.lang.Boolean> msetnx(java.util.Map<K,V> map)

objectEncoding

public java.util.concurrent.Future<java.lang.String> objectEncoding(K key)

objectIdletime

public java.util.concurrent.Future<java.lang.Long> objectIdletime(K key)

objectRefcount

public java.util.concurrent.Future<java.lang.Long> objectRefcount(K key)

persist

public java.util.concurrent.Future<java.lang.Boolean> persist(K key)

pexpire

public java.util.concurrent.Future<java.lang.Boolean> pexpire(K key,
                                                              long milliseconds)

pexpireat

public java.util.concurrent.Future<java.lang.Boolean> pexpireat(K key,
                                                                java.util.Date timestamp)

pexpireat

public java.util.concurrent.Future<java.lang.Boolean> pexpireat(K key,
                                                                long timestamp)

ping

public java.util.concurrent.Future<java.lang.String> ping()

pttl

public java.util.concurrent.Future<java.lang.Long> pttl(K key)

publish

public java.util.concurrent.Future<java.lang.Long> publish(K channel,
                                                           V message)

quit

public java.util.concurrent.Future<java.lang.String> quit()

randomkey

public java.util.concurrent.Future<V> randomkey()

rename

public java.util.concurrent.Future<java.lang.String> rename(K key,
                                                            K newKey)

renamenx

public java.util.concurrent.Future<java.lang.Boolean> renamenx(K key,
                                                               K newKey)

restore

public java.util.concurrent.Future<java.lang.String> restore(K key,
                                                             long ttl,
                                                             byte[] value)

rpop

public java.util.concurrent.Future<V> rpop(K key)

rpoplpush

public java.util.concurrent.Future<V> rpoplpush(K source,
                                                K destination)

rpush

public java.util.concurrent.Future<java.lang.Long> rpush(K key,
                                                         V... values)

rpushx

public java.util.concurrent.Future<java.lang.Long> rpushx(K key,
                                                          V value)

sadd

public java.util.concurrent.Future<java.lang.Long> sadd(K key,
                                                        V... members)

save

public java.util.concurrent.Future<java.lang.String> save()

scard

public java.util.concurrent.Future<java.lang.Long> scard(K key)

scriptExists

public java.util.concurrent.Future<java.util.List<java.lang.Boolean>> scriptExists(java.lang.String... digests)

scriptFlush

public java.util.concurrent.Future<java.lang.String> scriptFlush()

scriptKill

public java.util.concurrent.Future<java.lang.String> scriptKill()

scriptLoad

public java.util.concurrent.Future<java.lang.String> scriptLoad(V script)

sdiff

public java.util.concurrent.Future<java.util.Set<V>> sdiff(K... keys)

sdiffstore

public java.util.concurrent.Future<java.lang.Long> sdiffstore(K destination,
                                                              K... keys)

select

public java.lang.String select(int db)

set

public java.util.concurrent.Future<java.lang.String> set(K key,
                                                         V value)

setbit

public java.util.concurrent.Future<java.lang.Long> setbit(K key,
                                                          long offset,
                                                          int value)

setex

public java.util.concurrent.Future<java.lang.String> setex(K key,
                                                           long seconds,
                                                           V value)

setnx

public java.util.concurrent.Future<java.lang.Boolean> setnx(K key,
                                                            V value)

setrange

public java.util.concurrent.Future<java.lang.Long> setrange(K key,
                                                            long offset,
                                                            V value)

shutdown
```
@Deprecated
public void shutdown()
```
Deprecated.

shutdown
```
public void shutdown(boolean save)
```

sinter

public java.util.concurrent.Future<java.util.Set<V>> sinter(K... keys)

sinterstore

public java.util.concurrent.Future<java.lang.Long> sinterstore(K destination,
                                                               K... keys)

sismember

public java.util.concurrent.Future<java.lang.Boolean> sismember(K key,
                                                                V member)

smove

public java.util.concurrent.Future<java.lang.Boolean> smove(K source,
                                                            K destination,
                                                            V member)

slaveof

public java.util.concurrent.Future<java.lang.String> slaveof(java.lang.String host,
                                                             int port)

slaveofNoOne

public java.util.concurrent.Future<java.lang.String> slaveofNoOne()

slowlogGet

public java.util.concurrent.Future<java.util.List<java.lang.Object>> slowlogGet()

slowlogGet

public java.util.concurrent.Future<java.util.List<java.lang.Object>> slowlogGet(int count)

slowlogLen

public java.util.concurrent.Future<java.lang.Long> slowlogLen()

slowlogReset

public java.util.concurrent.Future<java.lang.String> slowlogReset()

smembers

public java.util.concurrent.Future<java.util.Set<V>> smembers(K key)

sort

public java.util.concurrent.Future<java.util.List<V>> sort(K key)

sort

public java.util.concurrent.Future<java.util.List<V>> sort(K key,
                                                           SortArgs sortArgs)

sortStore

public java.util.concurrent.Future<java.lang.Long> sortStore(K key,
                                                             SortArgs sortArgs,
                                                             K destination)

spop

public java.util.concurrent.Future<V> spop(K key)

srandmember

public java.util.concurrent.Future<V> srandmember(K key)

srandmember

public java.util.concurrent.Future<java.util.Set<V>> srandmember(K key,
                                                                 long count)

srem

public java.util.concurrent.Future<java.lang.Long> srem(K key,
                                                        V... members)

sunion

public java.util.concurrent.Future<java.util.Set<V>> sunion(K... keys)

sunionstore

public java.util.concurrent.Future<java.lang.Long> sunionstore(K destination,
                                                               K... keys)

sync

public java.util.concurrent.Future<java.lang.String> sync()

strlen

public java.util.concurrent.Future<java.lang.Long> strlen(K key)

ttl

public java.util.concurrent.Future<java.lang.Long> ttl(K key)

type

public java.util.concurrent.Future<java.lang.String> type(K key)

watch

public java.util.concurrent.Future<java.lang.String> watch(K... keys)

unwatch

public java.util.concurrent.Future<java.lang.String> unwatch()

zadd

public java.util.concurrent.Future<java.lang.Long> zadd(K key,
                                                        double score,
                                                        V member)

zadd

public java.util.concurrent.Future<java.lang.Long> zadd(K key,
                                                        java.lang.Object... scoresAndValues)

zcard

public java.util.concurrent.Future<java.lang.Long> zcard(K key)

zcount

public java.util.concurrent.Future<java.lang.Long> zcount(K key,
                                                          double min,
                                                          double max)

zcount

public java.util.concurrent.Future<java.lang.Long> zcount(K key,
                                                          java.lang.String min,
                                                          java.lang.String max)

zincrby

public java.util.concurrent.Future<java.lang.Double> zincrby(K key,
                                                             double amount,
                                                             K member)

zinterstore

public java.util.concurrent.Future<java.lang.Long> zinterstore(K destination,
                                                               K... keys)

zinterstore

public java.util.concurrent.Future<java.lang.Long> zinterstore(K destination,
                                                               ZStoreArgs storeArgs,
                                                               K... keys)

zrange

public java.util.concurrent.Future<java.util.List<V>> zrange(K key,
                                                             long start,
                                                             long stop)

zrangeWithScores

public java.util.concurrent.Future<java.util.List<ScoredValue<V>>> zrangeWithScores(K key,
                                                                                    long start,
                                                                                    long stop)

zrangebyscore

public java.util.concurrent.Future<java.util.List<V>> zrangebyscore(K key,
                                                                    double min,
                                                                    double max)

zrangebyscore

public java.util.concurrent.Future<java.util.List<V>> zrangebyscore(K key,
                                                                    java.lang.String min,
                                                                    java.lang.String max)

zrangebyscore

public java.util.concurrent.Future<java.util.List<V>> zrangebyscore(K key,
                                                                    double min,
                                                                    double max,
                                                                    long offset,
                                                                    long count)

zrangebyscore

public java.util.concurrent.Future<java.util.List<V>> zrangebyscore(K key,
                                                                    java.lang.String min,
                                                                    java.lang.String max,
                                                                    long offset,
                                                                    long count)

zrangebyscoreWithScores

public java.util.concurrent.Future<java.util.List<ScoredValue<V>>> zrangebyscoreWithScores(K key,
                                                                                           double min,
                                                                                           double max)

zrangebyscoreWithScores

public java.util.concurrent.Future<java.util.List<ScoredValue<V>>> zrangebyscoreWithScores(K key,
                                                                                           java.lang.String min,
                                                                                           java.lang.String max)

zrangebyscoreWithScores

public java.util.concurrent.Future<java.util.List<ScoredValue<V>>> zrangebyscoreWithScores(K key,
                                                                                           double min,
                                                                                           double max,
                                                                                           long offset,
                                                                                           long count)

zrangebyscoreWithScores

public java.util.concurrent.Future<java.util.List<ScoredValue<V>>> zrangebyscoreWithScores(K key,
                                                                                           java.lang.String min,
                                                                                           java.lang.String max,
                                                                                           long offset,
                                                                                           long count)

zrank

public java.util.concurrent.Future<java.lang.Long> zrank(K key,
                                                         V member)

zrem

public java.util.concurrent.Future<java.lang.Long> zrem(K key,
                                                        V... members)

zremrangebyrank

public java.util.concurrent.Future<java.lang.Long> zremrangebyrank(K key,
                                                                   long start,
                                                                   long stop)

zremrangebyscore

public java.util.concurrent.Future<java.lang.Long> zremrangebyscore(K key,
                                                                    double min,
                                                                    double max)

zremrangebyscore

public java.util.concurrent.Future<java.lang.Long> zremrangebyscore(K key,
                                                                    java.lang.String min,
                                                                    java.lang.String max)

zrevrange

public java.util.concurrent.Future<java.util.List<V>> zrevrange(K key,
                                                                long start,
                                                                long stop)

zrevrangeWithScores

public java.util.concurrent.Future<java.util.List<ScoredValue<V>>> zrevrangeWithScores(K key,
                                                                                       long start,
                                                                                       long stop)

zrevrangebyscore

public java.util.concurrent.Future<java.util.List<V>> zrevrangebyscore(K key,
                                                                       double max,
                                                                       double min)

zrevrangebyscore

public java.util.concurrent.Future<java.util.List<V>> zrevrangebyscore(K key,
                                                                       java.lang.String max,
                                                                       java.lang.String min)

zrevrangebyscore

public java.util.concurrent.Future<java.util.List<V>> zrevrangebyscore(K key,
                                                                       double max,
                                                                       double min,
                                                                       long offset,
                                                                       long count)

zrevrangebyscore

public java.util.concurrent.Future<java.util.List<V>> zrevrangebyscore(K key,
                                                                       java.lang.String max,
                                                                       java.lang.String min,
                                                                       long offset,
                                                                       long count)

zrevrangebyscoreWithScores

public java.util.concurrent.Future<java.util.List<ScoredValue<V>>> zrevrangebyscoreWithScores(K key,
                                                                                              double max,
                                                                                              double min)

zrevrangebyscoreWithScores

public java.util.concurrent.Future<java.util.List<ScoredValue<V>>> zrevrangebyscoreWithScores(K key,
                                                                                              java.lang.String max,
                                                                                              java.lang.String min)

zrevrangebyscoreWithScores

public java.util.concurrent.Future<java.util.List<ScoredValue<V>>> zrevrangebyscoreWithScores(K key,
                                                                                              double max,
                                                                                              double min,
                                                                                              long offset,
                                                                                              long count)

zrevrangebyscoreWithScores

public java.util.concurrent.Future<java.util.List<ScoredValue<V>>> zrevrangebyscoreWithScores(K key,
                                                                                              java.lang.String max,
                                                                                              java.lang.String min,
                                                                                              long offset,
                                                                                              long count)

zrevrank

public java.util.concurrent.Future<java.lang.Long> zrevrank(K key,
                                                            V member)

zscore

public java.util.concurrent.Future<java.lang.Double> zscore(K key,
                                                            V member)

zunionstore

public java.util.concurrent.Future<java.lang.Long> zunionstore(K destination,
                                                               K... keys)

zunionstore

public java.util.concurrent.Future<java.lang.Long> zunionstore(K destination,
                                                               ZStoreArgs storeArgs,
                                                               K... keys)

awaitAll
```
public boolean awaitAll(java.util.concurrent.Future<?>... futures)
```
Wait until commands are complete or the connection timeout is reached.

Parameters:

futures - Futures to wait for.

Returns:

True if all futures complete in time.

awaitAll
```
public boolean awaitAll(long timeout,
                        java.util.concurrent.TimeUnit unit,
                        java.util.concurrent.Future<?>... futures)
```
Wait until futures are complete or the supplied timeout is reached.

Parameters:

timeout - Maximum time to wait for futures to complete.

unit - Unit of time for the timeout.

futures - Futures to wait for.

Returns:

True if all futures complete in time.

close
```
public void close()
```
Close the connection.

digest

public java.lang.String digest(V script)

channelConnected

public void channelConnected(org.jboss.netty.channel.ChannelHandlerContext ctx,
                             org.jboss.netty.channel.ChannelStateEvent e)
                      throws java.lang.Exception

Overrides:: channelConnected in class org.jboss.netty.channel.SimpleChannelUpstreamHandler
Throws:: java.lang.Exception

channelClosed

public void channelClosed(org.jboss.netty.channel.ChannelHandlerContext ctx,
                          org.jboss.netty.channel.ChannelStateEvent e)
                   throws java.lang.Exception

Overrides:: channelClosed in class org.jboss.netty.channel.SimpleChannelUpstreamHandler
Throws:: java.lang.Exception

dispatch

public <T> Command<K,V,T> dispatch(CommandType type,
                                   CommandOutput<K,V,T> output)

dispatch

public <T> Command<K,V,T> dispatch(CommandType type,
                                   CommandOutput<K,V,T> output,
                                   K key)

dispatch

public <T> Command<K,V,T> dispatch(CommandType type,
                                   CommandOutput<K,V,T> output,
                                   K key,
                                   V value)

dispatch

public <T> Command<K,V,T> dispatch(CommandType type,
                                   CommandOutput<K,V,T> output,
                                   K key,
                                   V[] values)

dispatch

public <T> Command<K,V,T> dispatch(CommandType type,
                                   CommandOutput<K,V,T> output,
                                   CommandArgs<K,V> args)

await

public <T> T await(Command<K,V,T> cmd,
                   long timeout,
                   java.util.concurrent.TimeUnit unit)

newScriptOutput

protected <K,V,T> CommandOutput<K,V,T> newScriptOutput(RedisCodec<K,V> codec,
                                                       ScriptOutputType type)

string

public java.lang.String string(double n)

Class RedisAsyncConnection<K,V>

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler

Field Summary

Constructor Summary

Method Summary

Methods inherited from class org.jboss.netty.channel.SimpleChannelUpstreamHandler

Methods inherited from class java.lang.Object

Field Detail

queue

codec

channel

timeout

unit

multi

password

db

closed

Constructor Detail

RedisAsyncConnection

Method Detail

setTimeout

append

auth

bgrewriteaof

bgsave

bitcount

bitcount

bitopAnd

bitopNot

bitopOr

bitopXor

blpop

brpop

brpoplpush

clientGetname

clientSetname

clientKill

clientList

configGet

configResetstat

configSet

dbsize

debugObject

decr

decrby

del

discard

dump

echo

eval

evalsha

exists

expire

expireat

expireat

exec

flushall

flushdb

get

getbit

getrange

getset

hdel

hexists

hget

hincrby

hincrbyfloat

hgetall

hkeys

hlen

hmget

hmset

hset

hsetnx

hvals

incr

incrby

incrbyfloat

info