public class HttpClientTransportOverUnixSockets.UnixSocketSelectorManager extends AbstractConnectorHttpClientTransport.ClientSelectorManager
SelectorManager.AcceptListener
AbstractLifeCycle.AbstractLifeCycleListener
Container.InheritedListener, Container.Listener
LifeCycle.Listener
DEFAULT_CONNECT_TIMEOUT, LOG
Modifier | Constructor and Description |
---|---|
protected |
UnixSocketSelectorManager(HttpClient client,
int selectors) |
Modifier and Type | Method and Description |
---|---|
protected EndPoint |
newEndPoint(java.nio.channels.SelectableChannel channel,
ManagedSelector selector,
java.nio.channels.SelectionKey key)
Factory method to create
EndPoint . |
protected java.nio.channels.Selector |
newSelector() |
connectionFailed, newConnection
accept, accept, accepted, acceptor, addAcceptListener, addEventListener, connect, connectionClosed, connectionOpened, doAccept, doFinishConnect, doStart, doStop, endPointClosed, endPointOpened, execute, getConnectTimeout, getExecutor, getReservedThreads, getScheduler, getSelectorCount, isConnectionPending, newSelector, onAccepted, onAcceptFailed, onAccepting, removeAcceptListener, removeEventListener, setConnectTimeout, setReservedThreads
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
dump, dump, dump, dumpObject, dumpObjects, dumpSelf
protected UnixSocketSelectorManager(HttpClient client, int selectors)
protected java.nio.channels.Selector newSelector() throws java.io.IOException
newSelector
in class SelectorManager
java.io.IOException
protected EndPoint newEndPoint(java.nio.channels.SelectableChannel channel, ManagedSelector selector, java.nio.channels.SelectionKey key)
SelectorManager
Factory method to create EndPoint
.
This method is invoked as a result of the registration of a channel via SelectorManager.connect(SelectableChannel, Object)
or SelectorManager.accept(SelectableChannel)
.
newEndPoint
in class AbstractConnectorHttpClientTransport.ClientSelectorManager
channel
- the channel associated to the endpointselector
- the selector the channel is registered tokey
- the selection keySelectorManager.newConnection(SelectableChannel, EndPoint, Object)
Copyright © 1995–2023 Webtide. All rights reserved.