public class JRedisPipelineService extends SyncJRedisBase
CacheKeys
Constructor and Description |
---|
JRedisPipelineService(ConnectionSpec connectionSpec) |
JRedisPipelineService(String host,
int port,
String password,
int database) |
Modifier and Type | Method and Description |
---|---|
JRedis |
getInterface() |
protected Response |
serviceRequest(Command cmd,
byte[]... args)
This method mimics the eponymous
Connection#serviceRequest(Command, byte[]...)
which defines the blocking api semantics of Synchronous connections. |
protected void |
setConnection(Connection connection)
This extension point is really only necessary to allow this class to
set the
FaultedConnection when necessary, in course of the
SyncJRedisBase#createSyncConnection(String)
method operation. |
createSyncConnection, getContext, setContext
append, append, append, append, bgrewriteaof, bgsave, dbsize, debug, decr, decrby, del, discard, echo, echo, echo, echo, exists, expire, expireat, flushall, flushdb, get, getbit, getKeyBytes, getset, getset, getset, getset, hdel, hexists, hget, hgetall, hkeys, hlen, hset, hset, hset, hset, hvals, incr, incrby, info, keys, keys, lastsave, lindex, llen, lpop, lpush, lpush, lpush, lpush, lrange, lrem, lrem, lrem, lrem, lset, lset, lset, lset, ltrim, mget, move, mset, mset, mset, mset, mset, msetnx, msetnx, msetnx, msetnx, msetnx, multi, ping, quit, randomkey, rename, renamenx, rpop, rpoplpush, rpush, rpush, rpush, rpush, 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 JRedisPipelineService(String host, int port, String password, int database)
host
- port
- password
- database
- connectionCount
- public JRedisPipelineService(ConnectionSpec connectionSpec)
connectionSpec
- connectionCount
- protected final void setConnection(Connection connection)
SyncJRedisBase
FaultedConnection
when necessary, in course of the
SyncJRedisBase#createSyncConnection(String)
method operation.setConnection
in class SyncJRedisBase
protected Response serviceRequest(Command cmd, byte[]... args) throws RedisException, ClientRuntimeException, ProviderException
JRedisSupport
Connection#serviceRequest(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.serviceRequest
in class JRedisSupport
RedisException
ClientRuntimeException
ProviderException
public JRedis getInterface()
Copyright © 2009–2018. All rights reserved.