@ManagedObject public abstract class AbstractConnectorHttpClientTransport extends AbstractHttpClientTransport
| Modifier and Type | Class and Description |
|---|---|
protected class |
AbstractConnectorHttpClientTransport.ClientSelectorManager |
AbstractLifeCycle.AbstractLifeCycleListenerContainer.InheritedListener, Container.ListenerLifeCycle.ListenerLOGFAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPINGHTTP_CONNECTION_PROMISE_CONTEXT_KEY, HTTP_DESTINATION_CONTEXT_KEYCONNECTOR_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, setHttpClientaddBean, 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, updateBeansaddLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitnewHttpDestinationcustomize, newConnectiondumpObjects, dumpSelfprotected AbstractConnectorHttpClientTransport(int selectors)
@ManagedAttribute(value="The number of selectors", readonly=true) public int getSelectors()
protected void doStart()
throws java.lang.Exception
ContainerLifeCycledoStart in class ContainerLifeCyclejava.lang.Exceptionprotected void doStop()
throws java.lang.Exception
ContainerLifeCycledoStop in class ContainerLifeCyclejava.lang.Exceptionpublic void connect(java.net.InetSocketAddress address,
java.util.Map<java.lang.String,java.lang.Object> context)
HttpClientTransportaddress.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.IOExceptionprotected SelectorManager newSelectorManager(HttpClient client)
protected SelectorManager getSelectorManager()
Copyright © 1995–2022 Webtide. All rights reserved.