org.jredis.ri.alphazero

Class JRedisChunkedPipeline

java.lang.Object

org.jredis.ri.alphazero.JRedisFutureSupport

org.jredis.ri.alphazero.JRedisChunkedPipeline

All Implemented Interfaces:

JRedisFuture

public class JRedisChunkedPipeline
extends JRedisFutureSupport

An asynchronous pipeline supporting JRedisFuture api, utilizing the ChunkedPipelineConnection, providing maximal throughput as a forwarding pipe to Redis server. Thread safe. Use only one instance per application.

Nested Class Summary

Nested classes/interfaces inherited from class org.jredis.ri.alphazero.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

Field Summary

Fields

Modifier and Type	Field and Description
private Connection	connection

Fields inherited from class org.jredis.ri.alphazero.JRedisFutureSupport

CacheKeys

Constructor Summary

Constructors

Constructor and Description
JRedisChunkedPipeline(ConnectionSpec spec)

Method Summary

Modifier and Type	Method and Description
protected java.util.concurrent.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.

Methods inherited from class org.jredis.ri.alphazero.JRedisFutureSupport

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

connection

private final Connection connection

Constructor Detail

JRedisChunkedPipeline

public JRedisChunkedPipeline(ConnectionSpec spec)

Method Detail

queueRequest

protected java.util.concurrent.Future<Response> queueRequest(Command cmd,
                                                             byte[]... args)
                                                      throws ClientRuntimeException,
                                                             ProviderException

Description copied from class: JRedisFutureSupport

This method mimics the eponymous 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 Connections.

Specified by:

queueRequest in class JRedisFutureSupport

Returns:

Throws:

ClientRuntimeException

ProviderException