org.eclipse.jetty.websocket.client.io

Class WebSocketClientSelectorManager

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.io.SelectorManager

org.eclipse.jetty.websocket.client.io.WebSocketClientSelectorManager

All Implemented Interfaces:

Container, Destroyable, Dumpable, LifeCycle

public class WebSocketClientSelectorManager
extends SelectorManager

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Container

Container.InheritedListener, Container.Listener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

LifeCycle.Listener

Field Summary

Fields inherited from class org.eclipse.jetty.io.SelectorManager

DEFAULT_CONNECT_TIMEOUT

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Constructor Summary

Constructors

Constructor and Description
WebSocketClientSelectorManager(WebSocketClient client)

Method Summary

Modifier and Type	Method and Description
protected void	connectionFailed(SelectableChannel channel, Throwable ex, Object attachment) Callback method invoked when a non-blocking connect cannot be completed.
WebSocketPolicy	getPolicy()
SslContextFactory	getSslContextFactory()
Connection	newConnection(SelectableChannel channel, EndPoint endPoint, Object attachment) Factory method to create Connection.
protected EndPoint	newEndPoint(SelectableChannel channel, ManagedSelector selector, SelectionKey selectionKey) Factory method to create EndPoint.
SSLEngine	newSSLEngine(SslContextFactory sslContextFactory, SelectableChannel channel)
UpgradeConnection	newUpgradeConnection(SelectableChannel channel, EndPoint endPoint, ConnectPromise connectPromise)
void	setSslContextFactory(SslContextFactory sslContextFactory)

Methods inherited from class org.eclipse.jetty.io.SelectorManager

accept, accept, accepted, acceptor, connect, connectionClosed, connectionOpened, doAccept, doFinishConnect, doStart, doStop, endPointClosed, endPointOpened, execute, getConnectTimeout, getExecutor, getScheduler, getSelectorCount, isConnectionPending, newSelector, newSelector, setConnectTimeout

Methods inherited from class org.eclipse.jetty.util.component.ContainerLifeCycle

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

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dump, dump

Constructor Detail

WebSocketClientSelectorManager

public WebSocketClientSelectorManager(WebSocketClient client)

Method Detail

connectionFailed

protected void connectionFailed(SelectableChannel channel,
                                Throwable ex,
                                Object attachment)

Description copied from class: SelectorManager

Callback method invoked when a non-blocking connect cannot be completed.

By default it just logs with level warning.

Overrides:

connectionFailed in class SelectorManager

Parameters:

channel - the channel that attempted the connect

ex - the exception that caused the connect to fail

attachment - the attachment object associated at registration

getSslContextFactory

public SslContextFactory getSslContextFactory()

newConnection

public Connection newConnection(SelectableChannel channel,
                                EndPoint endPoint,
                                Object attachment)
                         throws IOException

Description copied from class: SelectorManager

Factory method to create Connection.

Specified by:

newConnection in class SelectorManager

Parameters:

channel - the channel associated to the connection

endPoint - the endpoint

attachment - the attachment

Returns:

a new connection

Throws:

IOException - if unable to create new connection

newEndPoint

protected EndPoint newEndPoint(SelectableChannel channel,
                               ManagedSelector selector,
                               SelectionKey selectionKey)
                        throws IOException

Description copied from class: 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).

Specified by:

newEndPoint in class SelectorManager

Parameters:

channel - the channel associated to the endpoint

selector - the selector the channel is registered to

selectionKey - the selection key

Returns:

a new endpoint

Throws:

IOException - if the endPoint cannot be created

See Also:

SelectorManager.newConnection(SelectableChannel, EndPoint, Object)

newSSLEngine

public SSLEngine newSSLEngine(SslContextFactory sslContextFactory,
                              SelectableChannel channel)

newUpgradeConnection

public UpgradeConnection newUpgradeConnection(SelectableChannel channel,
                                              EndPoint endPoint,
                                              ConnectPromise connectPromise)

setSslContextFactory

public void setSslContextFactory(SslContextFactory sslContextFactory)

getPolicy

public WebSocketPolicy getPolicy()