public class JRedisAsyncClient extends JRedisFutureSupport
JRedisFutureSupport.FutureBit, JRedisFutureSupport.FutureBoolean, JRedisFutureSupport.FutureByteArray, JRedisFutureSupport.FutureByteArrayList, JRedisFutureSupport.FutureDataDictionary, JRedisFutureSupport.FutureDouble, JRedisFutureSupport.FutureInfo, JRedisFutureSupport.FutureKeyList, JRedisFutureSupport.FutureLong, JRedisFutureSupport.FutureObjectInfo, JRedisFutureSupport.FutureRedisType, JRedisFutureSupport.FutureResultBase, JRedisFutureSupport.FutureSortStoreResp, JRedisFutureSupport.FutureStatus, JRedisFutureSupport.FutureString, JRedisFutureSupport.FutureZSetList| Modifier and Type | Field and Description |
|---|---|
private Connection |
connection |
protected ConnectionSpec |
connSpec |
CacheKeys| Constructor and Description |
|---|
JRedisAsyncClient(ConnectionSpec connectionSpec) |
| Modifier and Type | Method and Description |
|---|---|
private Connection |
createAsyncConnection() |
protected java.util.concurrent.Future<Response> |
queueRequest(Command cmd,
byte[]... args)
Requests to server are queued at this point.
|
append, append, append, append, bgrewriteaof, bgsave, dbsize, debug, decr, decrby, del, echo, echo, echo, echo, exists, expire, expireat, flush, flushall, flushdb, get, getbit, getset, getset, getset, getset, hdel, hexists, hget, hgetall, hincrby, hkeys, hlen, hset, hset, hset, hset, hvals, incr, incrby, info, keys, keys, keystolist, lastsave, lindex, linsert, linsertAfter, linsertBefore, llen, lpop, lpush, lpush, lpush, lpush, lpushx, lrange, lrem, lrem, lrem, lrem, lset, lset, lset, lset, ltrim, mget, move, mset, mset, mset, mset, mset, msetnx, msetnx, msetnx, msetnx, msetnx, ping, quit, randomkey, rename, renamenx, rpop, rpoplpush, rpush, rpush, rpush, rpush, rpushx, sadd, sadd, sadd, sadd, save, scard, sdiff, sdiffstore, set, set, set, set, setbit, setnx, setnx, setnx, setnx, sinter, sinterstore, sismember, sismember, sismember, sismember, slaveof, slaveofnone, smembers, smove, smove, smove, smove, sort, spop, srandmember, srem, srem, srem, srem, substr, sunion, sunionstore, ttl, type, zadd, zadd, zadd, zadd, zcard, zcount, zincrby, zincrby, zincrby, zincrby, zrange, zrangebyscore, zrangebyscoreSubset, zrangeSubset, zrank, zrank, zrank, zrank, zrem, zrem, zrem, zrem, zremrangebyrank, zremrangebyscore, zrevrange, zrevrangeSubset, zrevrank, zrevrank, zrevrank, zrevrank, zscore, zscore, zscore, zscoreprivate final Connection connection
protected final ConnectionSpec connSpec
public JRedisAsyncClient(ConnectionSpec connectionSpec)
connectionSpec - private final Connection createAsyncConnection()
protected java.util.concurrent.Future<Response> queueRequest(Command cmd, byte[]... args) throws ClientRuntimeException, ProviderException
Command.QUIT will
raise an exception indicating the pipeline is shutting down.queueRequest in class JRedisFutureSupportClientRuntimeExceptionProviderExceptionJRedisFutureSupport.queueRequest(org.jredis.protocol.Command, byte[][])