@ManagedObject public abstract class AbstractHttpClientTransport extends ContainerLifeCycle implements HttpClientTransport
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractHttpClientTransport.ClientSelectorManager |
AbstractLifeCycle.AbstractLifeCycleListener
Container.InheritedListener, Container.Listener
LifeCycle.Listener
Modifier and Type | Field and Description |
---|---|
protected static Logger |
LOG |
FAILED, RUNNING, STARTED, STARTING, STOP_ON_FAILURE, STOPPED, STOPPING
HTTP_CONNECTION_PROMISE_CONTEXT_KEY, HTTP_DESTINATION_CONTEXT_KEY
CONNECTOR_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, updateBeans
addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
newHttpDestination
customize, newConnection
protected static final Logger LOG
protected HttpClient getHttpClient()
public void setHttpClient(HttpClient client)
HttpClientTransport
HttpClient
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 HttpClientTransport
client
- the HttpClient
that uses this transport.@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
.connect
in interface HttpClientTransport
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–2017 Webtide. All rights reserved.