com.couchbase.client.http
Class AsyncConnectionManager

java.lang.Object
  extended by net.spy.memcached.compat.SpyObject
      extended by com.couchbase.client.http.AsyncConnectionManager

public class AsyncConnectionManager
extends net.spy.memcached.compat.SpyObject

An asynchronous HTTP connection manager.


Constructor Summary
AsyncConnectionManager(org.apache.http.HttpHost target, int maxConnections, org.apache.http.nio.NHttpClientHandler handler, org.apache.http.params.HttpParams params, RequeueOpCallback cb)
           
 
Method Summary
 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)


Copyright © 2006-2009 Dustin Sallings, 2009-2012 Couchbase, Inc.