@ManagedObject public abstract class AbstractConnectorHttpClientTransport extends AbstractHttpClientTransport
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractConnectorHttpClientTransport.ClientSelectorManager |
AbstractLifeCycle.AbstractLifeCycleListener
ClientConnectionFactory.Decorator
Container.InheritedListener, Container.Listener
LifeCycle.Listener
Modifier and Type | Field and Description |
---|---|
private SelectorManager |
selectorManager |
private int |
selectors |
LOG
FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING
HTTP_CONNECTION_PROMISE_CONTEXT_KEY, HTTP_DESTINATION_CONTEXT_KEY
CONNECTOR_CONTEXT_KEY
Modifier | Constructor and Description |
---|---|
protected |
AbstractConnectorHttpClientTransport(int selectors) |
Modifier and Type | Method and Description |
---|---|
protected void |
configure(HttpClient client,
java.nio.channels.SocketChannel channel) |
void |
connect(java.net.InetSocketAddress address,
java.util.Map<java.lang.String,java.lang.Object> context)
Establishes a physical connection to the given
address . |
protected void |
connectFailed(java.util.Map<java.lang.String,java.lang.Object> context,
java.lang.Throwable x) |
protected void |
doStart()
Starts the managed lifecycle beans in the order they were added.
|
protected void |
doStop()
Stops the managed lifecycle beans in the reverse order they were added.
|
protected SelectorManager |
getSelectorManager() |
int |
getSelectors() |
protected SelectorManager |
newSelectorManager(HttpClient client) |
getConnectionPoolFactory, getHttpClient, setConnectionPoolFactory, setHttpClient
addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dump, dump, dump, dumpBeans, dumpObject, dumpObjects, dumpStdErr, dumpThis, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, updateBean, updateBean, updateBeans
addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
newHttpDestination
customize, newConnection
dumpContainer, dumpIterable, dumpMapEntries, dumpObjects, dumpSelf, named
private final int selectors
private SelectorManager selectorManager
protected AbstractConnectorHttpClientTransport(int selectors)
@ManagedAttribute(value="The number of selectors", readonly=true) public int getSelectors()
protected void doStart() throws java.lang.Exception
ContainerLifeCycle
doStart
in class ContainerLifeCycle
java.lang.Exception
protected void doStop() throws java.lang.Exception
ContainerLifeCycle
doStop
in class ContainerLifeCycle
java.lang.Exception
public void connect(java.net.InetSocketAddress address, java.util.Map<java.lang.String,java.lang.Object> context)
HttpClientTransport
address
.address
- the address to connect tocontext
- the context information to establish the connectionprotected void connectFailed(java.util.Map<java.lang.String,java.lang.Object> context, java.lang.Throwable x)
protected void configure(HttpClient client, java.nio.channels.SocketChannel channel) throws java.io.IOException
java.io.IOException
protected SelectorManager newSelectorManager(HttpClient client)
protected SelectorManager getSelectorManager()