protected class AbstractHttpClientTransport.ClientSelectorManager extends SelectorManager
AbstractLifeCycle.AbstractLifeCycleListenerContainer.InheritedListener, Container.ListenerLifeCycle.ListenerDEFAULT_CONNECT_TIMEOUT, LOGFAILED, RUNNING, STARTED, STARTING, STOP_ON_FAILURE, STOPPED, STOPPING| Modifier | Constructor and Description |
|---|---|
protected |
ClientSelectorManager(HttpClient client,
int selectors) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
connectionFailed(java.nio.channels.SocketChannel channel,
java.lang.Throwable x,
java.lang.Object attachment) |
Connection |
newConnection(java.nio.channels.SocketChannel channel,
EndPoint endPoint,
java.lang.Object attachment) |
protected EndPoint |
newEndPoint(java.nio.channels.SocketChannel channel,
ManagedSelector selector,
java.nio.channels.SelectionKey key) |
accept, accept, accepted, acceptor, connect, connectionClosed, connectionOpened, doStart, doStop, endPointClosed, endPointOpened, execute, finishConnect, getConnectTimeout, getExecutionStrategyFactory, getExecutor, getScheduler, getSelectorCount, getSelectorPriorityDelta, newSelector, setConnectTimeout, setExecutionStrategyFactory, setSelectorPriorityDeltaaddBean, 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, stopprotected ClientSelectorManager(HttpClient client, int selectors)
protected EndPoint newEndPoint(java.nio.channels.SocketChannel channel, ManagedSelector selector, java.nio.channels.SelectionKey key)
newEndPoint in class SelectorManagerpublic Connection newConnection(java.nio.channels.SocketChannel channel, EndPoint endPoint, java.lang.Object attachment) throws java.io.IOException
newConnection in class SelectorManagerjava.io.IOExceptionprotected void connectionFailed(java.nio.channels.SocketChannel channel,
java.lang.Throwable x,
java.lang.Object attachment)
connectionFailed in class SelectorManagerCopyright © 1995–2018 Webtide. All rights reserved.