@ManagedObject public abstract class AbstractHttpClientTransport extends ContainerLifeCycle implements HttpClientTransport
| Modifier and Type | Class and Description |
|---|---|
protected class |
AbstractHttpClientTransport.ClientSelectorManager |
AbstractLifeCycle.AbstractLifeCycleListenerContainer.InheritedListener, Container.ListenerLifeCycle.Listener| Modifier and Type | Field and Description |
|---|---|
protected static Logger |
LOG |
FAILED, RUNNING, STARTED, STARTING, STOP_ON_FAILURE, STOPPED, STOPPINGHTTP_CONNECTION_PROMISE_CONTEXT_KEY, HTTP_DESTINATION_CONTEXT_KEYCONNECTOR_CONTEXT_KEY| Modifier | Constructor and Description |
|---|---|
protected |
AbstractHttpClientTransport(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 HttpClient |
getHttpClient() |
int |
getSelectors() |
protected SelectorManager |
newSelectorManager(HttpClient client) |
void |
setHttpClient(HttpClient client)
Sets the
HttpClient instance on this transport. |
addBean, addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dump, dump, dump, dumpBeans, dumpObject, dumpStdErr, dumpThis, getBean, getBeans, getBeans, isManaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, updateBean, updateBean, updateBeansaddLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stopclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitnewHttpDestinationcustomize, newConnectionprotected static final Logger LOG
protected HttpClient getHttpClient()
public void setHttpClient(HttpClient client)
HttpClientTransportHttpClient instance on this transport.
This is needed because of a chicken-egg problem: in order to create the HttpClient
a HttpClientTransport is needed, that therefore cannot have a reference yet to the
HttpClient.
setHttpClient in interface HttpClientTransportclient - the HttpClient that uses this transport.@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.connect in interface HttpClientTransportaddress - 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)
Copyright © 1995–2017 Webtide. All rights reserved.