org.jredis.ri.alphazero.connection

Class SyncConnection

java.lang.Object

org.jredis.ri.alphazero.connection.ConnectionBase

org.jredis.ri.alphazero.connection.SyncConnection

All Implemented Interfaces:

Connection

public class SyncConnection
extends ConnectionBase
implements Connection

[TODO: document me!]

Since:

alpha.0

Version:

alpha.0, Apr 10, 2009

Author:

Joubin Houshyar (alphazero@sensesay.net)

Nested Class Summary

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.ConnectionBase

spec

Constructor Summary

Constructors

Constructor and Description
SyncConnection(ConnectionSpec connectionSpec) This constructor will pass the connection spec to the super class constructor and create and install the Protocol handler delegate instance for this SyncConnection.

Method Summary

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

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

addListener, connect, disconnect, getInputStream, getOutputStream, getProtocolHandler, getSpec, initializeAsyncConnection, initializeComponents, initializeOnConnect, initializeSocketStreams, initializeSyncConnection, isConnected, newInputStream, newOutputStream, newProtocolHandler, notifyConnected, notifyDisconnected, notifyFaulted, notifyListeners, notifyShuttingDown, onConnectionFault, queueRequest, reconnect, removeListener, shutdown, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jredis.connector.Connection

addListener, getSpec, queueRequest, removeListener

Constructor Detail

SyncConnection

public SyncConnection(ConnectionSpec connectionSpec)
               throws ClientRuntimeException,
                      ProviderException

This constructor will pass the connection spec to the super class constructor and create and install the Protocol handler delegate instance for this SyncConnection. If you definitely need to specify the redis server version, and the protocol implementation for that version exists, you should use this constructor. Otherwise, it is recommended that the SyncConnection(ConnectionSpec)be used.

This constructor will open the socket connection immediately.

Parameters:

connectionSpec -

redisversion -

Throws:

ClientRuntimeException - due to either dns (host connectivity) or any IO issues related to establishing the socket connection to the specified server.

ProviderException - if the version specified is not supported.

Method Detail

getModality

public final Connection.Modality getModality()

serviceRequest

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

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