org.jredis.ri.alphazero

Class JRedisPipelineService

java.lang.Object

org.jredis.ri.alphazero.JRedisSupport

org.jredis.ri.alphazero.SyncJRedisBase

org.jredis.ri.alphazero.JRedisPipelineService

All Implemented Interfaces:

JRedis, Resource<JRedis>

public class JRedisPipelineService
extends SyncJRedisBase

Since:

alpha.0

Version:

alpha.0, Nov 6, 2009

Author:

Joubin Houshyar (alphazero@sensesay.net)

Field Summary

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

CacheKeys

Constructor Summary

Constructors

Constructor and Description
JRedisPipelineService(ConnectionSpec connectionSpec)
JRedisPipelineService(String host, int port, String password, int database)

Method Summary

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.

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

createSyncConnection, getContext, setContext

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

JRedisPipelineService

public JRedisPipelineService(String host,
                             int port,
                             String password,
                             int database)

Parameters:

host -

port -

password -

database -

connectionCount -

JRedisPipelineService

public JRedisPipelineService(ConnectionSpec connectionSpec)

Parameters:

connectionSpec -

connectionCount -

Method Detail

setConnection

protected final void setConnection(Connection connection)

Description copied from class: SyncJRedisBase

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.

Specified by:

setConnection in class SyncJRedisBase

serviceRequest

protected Response serviceRequest(Command cmd,
                                  byte[]... args)
                           throws RedisException,
                                  ClientRuntimeException,
                                  ProviderException

Description copied from class: JRedisSupport

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

Specified by:

serviceRequest in class JRedisSupport

Returns:

Throws:

RedisException

ClientRuntimeException

ProviderException

getInterface

public JRedis getInterface()

Returns:

the resource type specific interface.