org.jredis.ri.alphazero.connection

Class SyncPipelineConnection

java.lang.Object

org.jredis.ri.alphazero.connection.ConnectionBase

org.jredis.ri.alphazero.connection.PipelineConnectionBase

org.jredis.ri.alphazero.connection.SyncPipelineConnection

All Implemented Interfaces:

Connection

public class SyncPipelineConnection
extends PipelineConnectionBase

Synchronous PipelineConnectionBase extension.

Since:

alpha.0

Version:

alpha.0, Sep 7, 2009

Nested Class Summary

Nested classes/interfaces inherited from class org.jredis.ri.alphazero.connection.PipelineConnectionBase

PipelineConnectionBase.ResponseHandler

Nested classes/interfaces inherited from interface org.jredis.connector.Connection

Connection.Event, Connection.Factory, Connection.Flag, Connection.Listener, Connection.Modality, Connection.Property, Connection.Socket, Connection.State

Field Summary

Fields inherited from class org.jredis.ri.alphazero.connection.PipelineConnectionBase

pendingResponseQueue

Fields inherited from class org.jredis.ri.alphazero.connection.ConnectionBase

spec, thrdProtocol

Constructor Summary

Constructors

Constructor and Description
SyncPipelineConnection(ConnectionSpec spec)

Method Summary

Modifier and Type	Method and Description
Response	serviceRequest(Command cmd, byte[]... args) A blocking call to service the specified request.

Methods inherited from class org.jredis.ri.alphazero.connection.PipelineConnectionBase

initializeComponents, newInputStream, newProtocolHandler, notifyConnected, notifyDisconnected, onResponseHandlerError, queueRequest

Methods inherited from class org.jredis.ri.alphazero.connection.ConnectionBase

addListener, connect, disconnect, getInputStream, getOutputStream, getProtocolHandler, getSpec, initializeAsyncConnection, initializeOnConnect, initializeSocketStreams, initializeSyncConnection, isConnected, newOutputStream, notifyFaulted, notifyListeners, notifyShuttingDown, onConnectionFault, reconnect, removeListener, shutdown, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncPipelineConnection

public SyncPipelineConnection(ConnectionSpec spec)
                       throws ClientRuntimeException

Parameters:

spec -

Throws:

ClientRuntimeException

Method Detail

serviceRequest

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

Description copied from interface: Connection

A blocking call to service the specified request. This method will return upon the completion of the request response protocol with the connected redis server. Timeouts and related matters are not addressed by this method or the Protocol interface and can (and should) be addressed at the implementation level (for example when creating handler instances using a specification set, including max wait for synchronous response.)

Connection.Modality.Asynchronous handlers must always throw a ClientRuntimeException for this method which violates the contract for Connection.Modality.Asynchronous handlers.

Specified by:

serviceRequest in interface Connection

Overrides:

serviceRequest in class ConnectionBase

Returns:

Throws:

RedisException

ClientRuntimeException

ProviderException