public class JRedisPipeline extends JRedisFutureSupport
JRedisFuture and using
an AsyncPipelineConnection for command processing.
TODO: details the usage and characteristics.
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 |
CacheKeys| Constructor and Description |
|---|
JRedisPipeline(ConnectionSpec connectionSpec) |
| Modifier and Type | Method and Description |
|---|---|
protected java.util.concurrent.Future<Response> |
queueRequest(Command cmd,
byte[]... args)
Requests to server are queued at this point.
|
JRedis |
sync()
Provides a synchronous semantics interface (
JRedis) to this pipeline. |
JRedis |
sync(long timeout,
java.util.concurrent.TimeUnit unit) |
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
public JRedisPipeline(ConnectionSpec connectionSpec)
connectionSpec - 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[][])public JRedis sync()
JRedis) to this pipeline.
Note that this is not a thread-safe mechanism. If you need a pipeline
connection with support for concurrent synchronous semantics, use a JRedisPipelineService.JRedis interface for this pipeline.public JRedis sync(long timeout, java.util.concurrent.TimeUnit unit)
timeout - unit -