@ManagedObject public abstract class AbstractConnectorHttpClientTransport extends AbstractHttpClientTransport
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractConnectorHttpClientTransport.ClientSelectorManager |
AbstractLifeCycle.AbstractLifeCycleListener
Container.InheritedListener, Container.Listener
LifeCycle.Listener
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.
|
int |
getSelectors() |
protected SelectorManager |
newSelectorManager(HttpClient client) |
getConnectionPoolFactory, getHttpClient, setConnectionPoolFactory, setHttpClient
addBean, 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
dumpObjects, dumpSelf
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)
Copyright © 1995–2023 Webtide. All rights reserved.