com.couchbase.client.http

Class AsyncConnectionManager

java.lang.Object

net.spy.memcached.compat.SpyObject

com.couchbase.client.http.AsyncConnectionManager

public class AsyncConnectionManager
extends SpyObject

An asynchronous HTTP connection manager.

Constructor Summary

Constructors

Constructor and Description
AsyncConnectionManager(org.apache.http.HttpHost target, int maxConnections, org.apache.http.nio.NHttpClientHandler handler, org.apache.http.params.HttpParams params, RequeueOpCallback cb)

Method Summary

Methods

Modifier and Type	Method and Description
void	execute()
boolean	hasPendingRequests()
void	releaseConnection(org.apache.http.nio.NHttpClientConnection conn)
AsyncConnectionRequest	requestConnection()
void	shutdown(long waitMs)

Methods inherited from class net.spy.memcached.compat.SpyObject

getLogger

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncConnectionManager

public AsyncConnectionManager(org.apache.http.HttpHost target,
                      int maxConnections,
                      org.apache.http.nio.NHttpClientHandler handler,
                      org.apache.http.params.HttpParams params,
                      RequeueOpCallback cb)
                       throws org.apache.http.nio.reactor.IOReactorException

Throws:

org.apache.http.nio.reactor.IOReactorException

Method Detail

execute

public void execute()
             throws java.io.IOException

Throws:

java.io.IOException

hasPendingRequests

public boolean hasPendingRequests()

shutdown

public void shutdown(long waitMs)
              throws java.io.IOException

Throws:

java.io.IOException

requestConnection

public AsyncConnectionRequest requestConnection()

releaseConnection

public void releaseConnection(org.apache.http.nio.NHttpClientConnection conn)