public class WebSocketClientSelectorManager extends SelectorManager
SelectorManager.ManagedSelector, SelectorManager.SelectableEndPoint
AbstractLifeCycle.AbstractLifeCycleListener
LifeCycle.Listener
DEFAULT_CONNECT_TIMEOUT, SUBMIT_KEY_UPDATES
Constructor and Description |
---|
WebSocketClientSelectorManager(WebSocketClient client) |
Modifier and Type | Method and Description |
---|---|
protected void |
connectionFailed(SocketChannel channel,
Throwable ex,
Object attachment)
Callback method invoked when a non-blocking connect cannot be completed.
|
WebSocketPolicy |
getPolicy() |
SslContextFactory |
getSslContextFactory() |
Connection |
newConnection(SocketChannel channel,
EndPoint endPoint,
Object attachment)
Factory method to create
Connection . |
protected EndPoint |
newEndPoint(SocketChannel channel,
SelectorManager.ManagedSelector selectSet,
SelectionKey selectionKey)
Factory method to create
EndPoint . |
SSLEngine |
newSSLEngine(SslContextFactory sslContextFactory,
SocketChannel channel) |
UpgradeConnection |
newUpgradeConnection(SocketChannel channel,
EndPoint endPoint,
ConnectPromise connectPromise) |
void |
setSslContextFactory(SslContextFactory sslContextFactory) |
accept, accept, accepted, acceptor, connect, connectionClosed, connectionOpened, doStart, doStop, dump, dump, endPointClosed, endPointOpened, execute, finishConnect, getConnectTimeout, getExecutor, getScheduler, getSelectorCount, getSelectorPriorityDelta, newSelector, setConnectTimeout, setSelectorPriorityDelta
addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, setStopTimeout, start, stop
public WebSocketClientSelectorManager(WebSocketClient client)
protected void connectionFailed(SocketChannel channel, Throwable ex, Object attachment)
SelectorManager
Callback method invoked when a non-blocking connect cannot be completed.
By default it just logs with level warning.
connectionFailed
in class SelectorManager
channel
- the channel that attempted the connectex
- the exception that caused the connect to failattachment
- the attachment object associated at registrationpublic SslContextFactory getSslContextFactory()
public Connection newConnection(SocketChannel channel, EndPoint endPoint, Object attachment) throws IOException
SelectorManager
Factory method to create Connection
.
newConnection
in class SelectorManager
channel
- the channel associated to the connectionendPoint
- the endpointattachment
- the attachmentIOException
SelectorManager.newEndPoint(SocketChannel, ManagedSelector, SelectionKey)
protected EndPoint newEndPoint(SocketChannel channel, SelectorManager.ManagedSelector selectSet, SelectionKey selectionKey) throws IOException
SelectorManager
Factory method to create EndPoint
.
This method is invoked as a result of the registration of a channel via SelectorManager.connect(SocketChannel, Object)
or SelectorManager.accept(SocketChannel)
.
newEndPoint
in class SelectorManager
channel
- the channel associated to the endpointselectSet
- the selector the channel is registered toselectionKey
- the selection keyIOException
- if the endPoint cannot be createdSelectorManager.newConnection(SocketChannel, EndPoint, Object)
public SSLEngine newSSLEngine(SslContextFactory sslContextFactory, SocketChannel channel)
public UpgradeConnection newUpgradeConnection(SocketChannel channel, EndPoint endPoint, ConnectPromise connectPromise)
public void setSslContextFactory(SslContextFactory sslContextFactory)
public WebSocketPolicy getPolicy()
Copyright © 1995-2015 Webtide. All Rights Reserved.