abstract class CloseableHttpAsyncClientBase extends CloseableHttpPipeliningClient
Modifier and Type | Class and Description |
---|---|
(package private) static class |
CloseableHttpAsyncClientBase.Status |
Modifier and Type | Field and Description |
---|---|
private NHttpClientConnectionManager |
connmgr |
private org.apache.commons.logging.Log |
log |
private java.lang.Thread |
reactorThread |
private java.util.concurrent.atomic.AtomicReference<CloseableHttpAsyncClientBase.Status> |
status |
Constructor and Description |
---|
CloseableHttpAsyncClientBase(NHttpClientConnectionManager connmgr,
java.util.concurrent.ThreadFactory threadFactory,
org.apache.http.nio.NHttpClientEventHandler handler) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected void |
ensureRunning() |
boolean |
isRunning() |
void |
start() |
execute, execute, execute
execute, execute, execute, execute, execute
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
execute
private final org.apache.commons.logging.Log log
private final NHttpClientConnectionManager connmgr
private final java.lang.Thread reactorThread
private final java.util.concurrent.atomic.AtomicReference<CloseableHttpAsyncClientBase.Status> status
public CloseableHttpAsyncClientBase(NHttpClientConnectionManager connmgr, java.util.concurrent.ThreadFactory threadFactory, org.apache.http.nio.NHttpClientEventHandler handler)
public void start()
start
in class CloseableHttpAsyncClient
protected void ensureRunning()
public void close()
public boolean isRunning()
isRunning
in class CloseableHttpAsyncClient