public class JRedisChunkedPipeline extends JRedisFutureSupport
JRedisFuture
api,
utilizing the ChunkedPipelineConnection
, providing
maximal throughput as a forwarding pipe to Redis server.
Thread safe. Use only one instance per application.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
CacheKeys
Constructor and Description |
---|
JRedisChunkedPipeline(ConnectionSpec spec) |
Modifier and Type | Method and Description |
---|---|
protected Future<Response> |
queueRequest(Command cmd,
byte[]... args)
This method mimics the eponymous
Connection#queueRequest(Command, byte[]...)
which defines the blocking api semantics of Synchronous connections. |
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, zscore
public JRedisChunkedPipeline(ConnectionSpec spec)
protected Future<Response> queueRequest(Command cmd, byte[]... args) throws ClientRuntimeException, ProviderException
JRedisFutureSupport
Connection#queueRequest(Command, byte[]...)
which defines the blocking api semantics of Synchronous connections. The extending class
can either directly (a) implement the protocol requirements, or, (b) delegate to a
Connection
instance, or, (c) utilize a pool of Connection
s.queueRequest
in class JRedisFutureSupport
ClientRuntimeException
ProviderException
Copyright © 2009–2019. All rights reserved.