org.jredis.ri.alphazero.connection

Class AsyncPipelineConnection

java.lang.Object

org.jredis.ri.alphazero.connection.ConnectionBase

org.jredis.ri.alphazero.connection.PipelineConnectionBase

org.jredis.ri.alphazero.connection.AsyncPipelineConnection

All Implemented Interfaces:

Connection

public class AsyncPipelineConnection
extends PipelineConnectionBase

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
AsyncPipelineConnection(ConnectionSpec spec)

Method Summary

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, serviceRequest, shutdown, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncPipelineConnection

public AsyncPipelineConnection(ConnectionSpec spec)
                        throws ClientRuntimeException

Parameters:

spec -

Throws:

ClientRuntimeException