redis.clients.jedis

Class Pipeline

java.lang.Object

redis.clients.jedis.Queable

redis.clients.jedis.PipelineBase

redis.clients.jedis.MultiKeyPipelineBase

redis.clients.jedis.Pipeline

All Implemented Interfaces:

BasicRedisPipeline, BinaryRedisPipeline, ClusterPipeline, MultiKeyBinaryRedisPipeline, MultiKeyCommandsPipeline, RedisPipeline

Direct Known Subclasses:

PipelineBlock

public class Pipeline
extends MultiKeyPipelineBase

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	Pipeline.MultiResponseBuilder

Field Summary

Fields

Modifier and Type	Field and Description
private Pipeline.MultiResponseBuilder	currentMulti

Fields inherited from class redis.clients.jedis.MultiKeyPipelineBase

client

Constructor Summary

Constructors

Constructor and Description
Pipeline()

Method Summary

Modifier and Type	Method and Description
Response<java.lang.String>	discard()
Response<java.util.List<java.lang.Object>>	exec()
protected Client	getClient(byte[] key)
protected Client	getClient(java.lang.String key)
protected <T> Response<T>	getResponse(Builder<T> builder)
Response<java.lang.String>	multi()
void	setClient(Client client)
void	sync() Synchronize pipeline by reading all responses.
java.util.List<java.lang.Object>	syncAndReturnAll() Synchronize pipeline by reading all responses.

Methods inherited from class redis.clients.jedis.MultiKeyPipelineBase

bgrewriteaof, bgsave, bitop, bitop, blpop, blpop, blpop, blpop, blpopMap, brpop, brpop, brpop, brpop, brpoplpush, brpoplpush, brpopMap, clusterAddSlots, clusterDelSlots, clusterGetKeysInSlot, clusterInfo, clusterMeet, clusterNodes, clusterSetSlotImporting, clusterSetSlotMigrating, clusterSetSlotNode, configGet, configResetStat, configSet, dbSize, del, del, flushAll, flushDB, info, info, keys, keys, lastsave, mget, mget, mset, mset, msetnx, msetnx, pfcount, pfcount, pfmerge, pfmerge, ping, publish, publish, randomKey, randomKeyBinary, rename, rename, renamenx, renamenx, rpoplpush, rpoplpush, save, sdiff, sdiff, sdiffstore, sdiffstore, select, shutdown, sinter, sinter, sinterstore, sinterstore, smove, smove, sort, sort, sort, sort, sunion, sunion, sunionstore, sunionstore, time, watch, watch, zinterstore, zinterstore, zinterstore, zinterstore, zunionstore, zunionstore, zunionstore, zunionstore

Methods inherited from class redis.clients.jedis.PipelineBase

append, append, bitcount, bitcount, bitcount, bitcount, bitpos, bitpos, bitpos, bitpos, blpop, blpop, brpop, brpop, decr, decr, decrBy, decrBy, del, del, dump, dump, echo, echo, eval, eval, eval, evalsha, evalsha, evalsha, exists, exists, expire, expire, expireAt, expireAt, get, get, getbit, getbit, getrange, getrange, getSet, getSet, hdel, hdel, hexists, hexists, hget, hget, hgetAll, hgetAll, hincrBy, hincrBy, hincrByFloat, hincrByFloat, hkeys, hkeys, hlen, hlen, hmget, hmget, hmset, hmset, hset, hset, hsetnx, hsetnx, hvals, hvals, incr, incr, incrBy, incrBy, incrByFloat, incrByFloat, lindex, lindex, linsert, linsert, llen, llen, lpop, lpop, lpush, lpush, lpushx, lpushx, lrange, lrange, lrem, lrem, lset, lset, ltrim, ltrim, migrate, migrate, move, move, objectEncoding, objectEncoding, objectIdletime, objectIdletime, objectRefcount, objectRefcount, persist, persist, pexpire, pexpire, pexpire, pexpire, pexpireAt, pexpireAt, pfadd, pfadd, pfcount, pfcount, psetex, psetex, psetex, psetex, pttl, pttl, restore, restore, rpop, rpop, rpush, rpush, rpushx, rpushx, sadd, sadd, scard, scard, set, set, set, set, set, set, setbit, setbit, setex, setex, setnx, setnx, setrange, setrange, sismember, sismember, smembers, smembers, sort, sort, sort, sort, spop, spop, spop, spop, srandmember, srandmember, srandmember, srandmember, srem, srem, strlen, strlen, substr, substr, ttl, ttl, type, type, zadd, zadd, zadd, zcard, zcard, zcount, zcount, zcount, zcount, zincrby, zincrby, zlexcount, zlexcount, zrange, zrange, zrangeByLex, zrangeByLex, zrangeByLex, zrangeByLex, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeWithScores, zrangeWithScores, zrank, zrank, zrem, zrem, zremrangeByLex, zremrangeByLex, zremrangeByRank, zremrangeByRank, zremrangeByScore, zremrangeByScore, zremrangeByScore, zremrangeByScore, zrevrange, zrevrange, zrevrangeByLex, zrevrangeByLex, zrevrangeByLex, zrevrangeByLex, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zrevrank, zscore, zscore

Methods inherited from class redis.clients.jedis.Queable

clean, generateResponse, getPipelinedResponseLength, hasPipelinedResponse

Methods inherited from class java.lang.Object

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

Field Detail

currentMulti

private Pipeline.MultiResponseBuilder currentMulti

Constructor Detail

Pipeline

public Pipeline()

Method Detail

getResponse

protected <T> Response<T> getResponse(Builder<T> builder)

Overrides:

getResponse in class Queable

setClient

public void setClient(Client client)

getClient

protected Client getClient(byte[] key)

Specified by:

getClient in class PipelineBase

getClient

protected Client getClient(java.lang.String key)

Specified by:

getClient in class PipelineBase

sync

public void sync()

Synchronize pipeline by reading all responses. This operation close the pipeline. In order to get return values from pipelined commands, capture the different Response of the commands you execute.

syncAndReturnAll

public java.util.List<java.lang.Object> syncAndReturnAll()

Synchronize pipeline by reading all responses. This operation close the pipeline. Whenever possible try to avoid using this version and use Pipeline.sync() as it won't go through all the responses and generate the right response type (usually it is a waste of time).

Returns:

A list of all the responses in the order you executed them.

discard

public Response<java.lang.String> discard()

exec

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

multi

public Response<java.lang.String> multi()