org.eclipse.jetty.websocket.client

Class WebSocketClient

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.websocket.client.WebSocketClient

All Implemented Interfaces:

Container, Destroyable, Dumpable, LifeCycle, WebSocketContainerScope

public class WebSocketClient
extends ContainerLifeCycle
implements WebSocketContainerScope

WebSocketClient provides a means of establishing connections to remote websocket endpoints.

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.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

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

KEY

Constructor Summary

Constructors

Constructor and Description
WebSocketClient() Instantiate a WebSocketClient with defaults
WebSocketClient(ByteBufferPool bufferPool) Create a new WebSocketClient
WebSocketClient(java.util.concurrent.Executor executor) Create a new WebSocketClient
WebSocketClient(HttpClient httpClient) Instantiate a WebSocketClient using HttpClient for defaults
WebSocketClient(HttpClient httpClient, DecoratedObjectFactory objectFactory) Instantiate a WebSocketClient using HttpClient for defaults
WebSocketClient(SslContextFactory sslContextFactory) Create a new WebSocketClient
WebSocketClient(SslContextFactory sslContextFactory, java.util.concurrent.Executor executor) Create a new WebSocketClient
WebSocketClient(SslContextFactory sslContextFactory, java.util.concurrent.Executor executor, ByteBufferPool bufferPool) Create WebSocketClient using sharing instances of SSLContextFactory Executor, and ByteBufferPool
WebSocketClient(WebSocketContainerScope scope) Create WebSocketClient other Container Scope, to allow sharing of internal features like Executor, ByteBufferPool, SSLContextFactory, etc.
WebSocketClient(WebSocketContainerScope scope, EventDriverFactory eventDriverFactory, SessionFactory sessionFactory) Create WebSocketClient based on pre-existing Container Scope, to allow sharing of internal features like Executor, ByteBufferPool, SSLContextFactory, etc.
WebSocketClient(WebSocketContainerScope scope, EventDriverFactory eventDriverFactory, SessionFactory sessionFactory, HttpClient httpClient) Create WebSocketClient based on pre-existing Container Scope, to allow sharing of internal features like Executor, ByteBufferPool, SSLContextFactory, etc.
WebSocketClient(WebSocketContainerScope scope, SslContextFactory sslContextFactory) Create WebSocketClient other Container Scope, to allow sharing of internal features like Executor, ByteBufferPool, SSLContextFactory, etc.

Method Summary

Modifier and Type	Method and Description
void	addSessionListener(WebSocketSessionListener listener)
java.util.concurrent.Future<Session>	connect(java.lang.Object websocket, java.net.URI toUri)
java.util.concurrent.Future<Session>	connect(java.lang.Object websocket, java.net.URI toUri, ClientUpgradeRequest request) Connect to remote websocket endpoint
java.util.concurrent.Future<Session>	connect(java.lang.Object websocket, java.net.URI toUri, ClientUpgradeRequest request, UpgradeListener upgradeListener) Connect to remote websocket endpoint
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.
boolean	equals(java.lang.Object o)
long	getAsyncWriteTimeout() Return the number of milliseconds for a timeout of an attempted write operation.
java.net.SocketAddress	getBindAddress()
ByteBufferPool	getBufferPool() The configured Container Buffer Pool.
ConnectionManager	getConnectionManager() Deprecated.
long	getConnectTimeout()
java.net.CookieStore	getCookieStore()
EventDriverFactory	getEventDriverFactory()
java.util.concurrent.Executor	getExecutor() Executor in use by the container.
ExtensionFactory	getExtensionFactory()
HttpClient	getHttpClient() Get the internal HttpClient.
Masker	getMasker() Deprecated. not used, no replacement
int	getMaxBinaryMessageBufferSize() Get the maximum size for buffering of a binary message.
long	getMaxBinaryMessageSize() Get the maximum size for a binary message.
long	getMaxIdleTimeout() Get the max idle timeout for new connections.
int	getMaxTextMessageBufferSize() Get the maximum size for buffering of a text message.
long	getMaxTextMessageSize() Get the maximum size for a text message.
DecoratedObjectFactory	getObjectFactory() Object Factory used to create objects.
java.util.Set<WebSocketSession>	getOpenSessions()
WebSocketPolicy	getPolicy() The policy the container is running on.
Scheduler	getScheduler()
SessionFactory	getSessionFactory()
java.util.Collection<WebSocketSessionListener>	getSessionListeners()
SslContextFactory	getSslContextFactory() Get the in use SslContextFactory
int	hashCode()
boolean	isDispatchIO() Deprecated.
boolean	isStopAtShutdown()
protected ConnectionManager	newConnectionManager() Deprecated. has no replacement
void	removeSessionListener(WebSocketSessionListener listener)
void	setAsyncWriteTimeout(long ms)
void	setBindAdddress(java.net.SocketAddress bindAddress) Deprecated. (this is a bad bad bad typo, it has 3 "d" characters in a row) use HttpClient.setBindAddress(SocketAddress) to the internal WebSocketClient(HttpClient)
void	setBindAddress(java.net.SocketAddress bindAddress) Sets the Bind Address on the internal HttpClient.
void	setBufferPool(ByteBufferPool bufferPool) Set's the Bind Address on the internal HttpClient.
void	setConnectTimeout(long ms) Set the timeout for connecting to the remote server on the internal HttpClient
void	setCookieStore(java.net.CookieStore cookieStore) Set the CookieStore to use on the internal HttpClient
void	setDaemon(boolean daemon) Deprecated. not used, configure threading in HttpClient instead
void	setDispatchIO(boolean dispatchIO) Deprecated. no longer used, this has no replacement
void	setExecutor(java.util.concurrent.Executor executor) Sets the Executor in use on the internal HttpClient
void	setMasker(Masker masker) Deprecated. not used, no replacement
void	setMaxBinaryMessageBufferSize(int max)
void	setMaxIdleTimeout(long ms) Set the max idle timeout for new connections.
void	setMaxTextMessageBufferSize(int max)
void	setStopAtShutdown(boolean stop) Set JVM shutdown behavior.
java.lang.String	toString()

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

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

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, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.eclipse.jetty.websocket.common.scopes.WebSocketContainerScope

isRunning

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

dumpObjects, dumpSelf

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

start, stop

Constructor Detail

WebSocketClient

public WebSocketClient()

Instantiate a WebSocketClient with defaults

WebSocketClient

public WebSocketClient(HttpClient httpClient)

Instantiate a WebSocketClient using HttpClient for defaults

Parameters:

httpClient - the HttpClient to base internal defaults off of

WebSocketClient

public WebSocketClient(HttpClient httpClient,
                       DecoratedObjectFactory objectFactory)

Instantiate a WebSocketClient using HttpClient for defaults

Parameters:

httpClient - the HttpClient to base internal defaults off of

objectFactory - the DecoratedObjectFactory for all client instantiated classes

WebSocketClient

public WebSocketClient(SslContextFactory sslContextFactory)

Create a new WebSocketClient

Parameters:

sslContextFactory - ssl context factory to use on the internal HttpClient

WebSocketClient

public WebSocketClient(java.util.concurrent.Executor executor)

Create a new WebSocketClient

Parameters:

executor - the executor to use on the internal HttpClient

WebSocketClient

public WebSocketClient(ByteBufferPool bufferPool)

Create a new WebSocketClient

Parameters:

bufferPool - byte buffer pool to use on the internal HttpClient

WebSocketClient

public WebSocketClient(SslContextFactory sslContextFactory,
                       java.util.concurrent.Executor executor)

Create a new WebSocketClient

Parameters:

sslContextFactory - ssl context factory to use on the internal HttpClient

executor - the executor to use on the internal HttpClient

WebSocketClient

public WebSocketClient(WebSocketContainerScope scope)

Create WebSocketClient other Container Scope, to allow sharing of internal features like Executor, ByteBufferPool, SSLContextFactory, etc.

Parameters:

scope - the Container Scope

WebSocketClient

public WebSocketClient(WebSocketContainerScope scope,
                       SslContextFactory sslContextFactory)

Create WebSocketClient other Container Scope, to allow sharing of internal features like Executor, ByteBufferPool, SSLContextFactory, etc.

Parameters:

scope - the Container Scope

sslContextFactory - SSL ContextFactory to use in preference to one from WebSocketContainerScope.getSslContextFactory()

WebSocketClient

public WebSocketClient(SslContextFactory sslContextFactory,
                       java.util.concurrent.Executor executor,
                       ByteBufferPool bufferPool)

Create WebSocketClient using sharing instances of SSLContextFactory Executor, and ByteBufferPool

Parameters:

sslContextFactory - shared SSL ContextFactory

executor - shared Executor

bufferPool - shared ByteBufferPool

WebSocketClient

public WebSocketClient(WebSocketContainerScope scope,
                       EventDriverFactory eventDriverFactory,
                       SessionFactory sessionFactory)

Create WebSocketClient based on pre-existing Container Scope, to allow sharing of internal features like Executor, ByteBufferPool, SSLContextFactory, etc.

Parameters:

scope - the Container Scope

eventDriverFactory - the EventDriver Factory to use

sessionFactory - the SessionFactory to use

WebSocketClient

public WebSocketClient(WebSocketContainerScope scope,
                       EventDriverFactory eventDriverFactory,
                       SessionFactory sessionFactory,
                       HttpClient httpClient)

Create WebSocketClient based on pre-existing Container Scope, to allow sharing of internal features like Executor, ByteBufferPool, SSLContextFactory, etc.

Parameters:

scope - the Container Scope

eventDriverFactory - the EventDriver Factory to use

sessionFactory - the SessionFactory to use

httpClient - the httpClient to use

Method Detail

connect

public java.util.concurrent.Future<Session> connect(java.lang.Object websocket,
                                                    java.net.URI toUri)
                                             throws java.io.IOException

Throws:

java.io.IOException

connect

public java.util.concurrent.Future<Session> connect(java.lang.Object websocket,
                                                    java.net.URI toUri,
                                                    ClientUpgradeRequest request)
                                             throws java.io.IOException

Connect to remote websocket endpoint

Parameters:

websocket - the websocket object

toUri - the websocket uri to connect to

request - the upgrade request information

Returns:

the future for the session, available on success of connect

Throws:

java.io.IOException - if unable to connect

connect

public java.util.concurrent.Future<Session> connect(java.lang.Object websocket,
                                                    java.net.URI toUri,
                                                    ClientUpgradeRequest request,
                                                    UpgradeListener upgradeListener)
                                             throws java.io.IOException

Connect to remote websocket endpoint

Parameters:

websocket - the websocket object

toUri - the websocket uri to connect to

request - the upgrade request information

upgradeListener - the upgrade listener

Returns:

the future for the session, available on success of connect

Throws:

java.io.IOException - if unable to connect

doStart

protected void doStart()
                throws java.lang.Exception

Description copied from class: ContainerLifeCycle

Starts the managed lifecycle beans in the order they were added.

Overrides:

doStart in class ContainerLifeCycle

Throws:

java.lang.Exception

doStop

protected void doStop()
               throws java.lang.Exception

Description copied from class: ContainerLifeCycle

Stops the managed lifecycle beans in the reverse order they were added.

Overrides:

doStop in class ContainerLifeCycle

Throws:

java.lang.Exception

isDispatchIO

@Deprecated
public boolean isDispatchIO()

Deprecated.

getAsyncWriteTimeout

public long getAsyncWriteTimeout()

Return the number of milliseconds for a timeout of an attempted write operation.

Returns:

number of milliseconds for timeout of an attempted write operation

getBindAddress

public java.net.SocketAddress getBindAddress()

getBufferPool

public ByteBufferPool getBufferPool()

Description copied from interface: WebSocketContainerScope

The configured Container Buffer Pool.

Specified by:

getBufferPool in interface WebSocketContainerScope

Returns:

the buffer pool (never null)

getConnectionManager

@Deprecated
public ConnectionManager getConnectionManager()

Deprecated.

getConnectTimeout

public long getConnectTimeout()

getCookieStore

public java.net.CookieStore getCookieStore()

getEventDriverFactory

public EventDriverFactory getEventDriverFactory()

getExecutor

public java.util.concurrent.Executor getExecutor()

Description copied from interface: WebSocketContainerScope

Executor in use by the container.

Specified by:

getExecutor in interface WebSocketContainerScope

Returns:

the Executor in use by the container.

getExtensionFactory

public ExtensionFactory getExtensionFactory()

getMasker

@Deprecated
public Masker getMasker()

Deprecated. not used, no replacement

Returns:

a RandomMasker instance

getMaxBinaryMessageBufferSize

public int getMaxBinaryMessageBufferSize()

Get the maximum size for buffering of a binary message.

Returns:

the maximum size of a binary message buffer.

getMaxBinaryMessageSize

public long getMaxBinaryMessageSize()

Get the maximum size for a binary message.

Returns:

the maximum size of a binary message.

getMaxIdleTimeout

public long getMaxIdleTimeout()

Get the max idle timeout for new connections.

Returns:

the max idle timeout in milliseconds for new connections.

getMaxTextMessageBufferSize

public int getMaxTextMessageBufferSize()

Get the maximum size for buffering of a text message.

Returns:

the maximum size of a text message buffer.

getMaxTextMessageSize

public long getMaxTextMessageSize()

Get the maximum size for a text message.

Returns:

the maximum size of a text message.

getObjectFactory

public DecoratedObjectFactory getObjectFactory()

Description copied from interface: WebSocketContainerScope

Object Factory used to create objects.

Specified by:

getObjectFactory in interface WebSocketContainerScope

Returns:

Object Factory used to create instances of objects.

getOpenSessions

public java.util.Set<WebSocketSession> getOpenSessions()

getPolicy

public WebSocketPolicy getPolicy()

Description copied from interface: WebSocketContainerScope

The policy the container is running on.

Specified by:

getPolicy in interface WebSocketContainerScope

Returns:

the websocket policy

getScheduler

public Scheduler getScheduler()

getSessionFactory

public SessionFactory getSessionFactory()

getSslContextFactory

public SslContextFactory getSslContextFactory()

Get the in use SslContextFactory

Specified by:

getSslContextFactory in interface WebSocketContainerScope

Returns:

the SslContextFactory that manages TLS encryption on the internal HttpClient

See Also:

WebSocketClient(SslContextFactory)

addSessionListener

public void addSessionListener(WebSocketSessionListener listener)

Specified by:

addSessionListener in interface WebSocketContainerScope

removeSessionListener

public void removeSessionListener(WebSocketSessionListener listener)

Specified by:

removeSessionListener in interface WebSocketContainerScope

getSessionListeners

public java.util.Collection<WebSocketSessionListener> getSessionListeners()

Specified by:

getSessionListeners in interface WebSocketContainerScope

newConnectionManager

@Deprecated
protected ConnectionManager newConnectionManager()

Deprecated. has no replacement

Factory method for new ConnectionManager

Returns:

the ConnectionManager instance to use

setAsyncWriteTimeout

public void setAsyncWriteTimeout(long ms)

setBindAdddress

@Deprecated
public void setBindAdddress(java.net.SocketAddress bindAddress)

Deprecated. (this is a bad bad bad typo, it has 3 "d" characters in a row) use HttpClient.setBindAddress(SocketAddress) to the internal WebSocketClient(HttpClient)

Parameters:

bindAddress - the address to bind to the internal HttpClient

setBindAddress

public void setBindAddress(java.net.SocketAddress bindAddress)

Sets the Bind Address on the internal HttpClient.

Parameters:

bindAddress - the local bind address for the internal HttpClient

setBufferPool

public void setBufferPool(ByteBufferPool bufferPool)

Set's the Bind Address on the internal HttpClient.

Parameters:

bufferPool - The buffer pool

setConnectTimeout

public void setConnectTimeout(long ms)

Set the timeout for connecting to the remote server on the internal HttpClient

Parameters:

ms - the timeout in milliseconds

setCookieStore

public void setCookieStore(java.net.CookieStore cookieStore)

Set the CookieStore to use on the internal HttpClient

Parameters:

cookieStore - The cookie store

setDaemon

@Deprecated
public void setDaemon(boolean daemon)

Deprecated. not used, configure threading in HttpClient instead

Parameters:

daemon - do nothing

setDispatchIO

@Deprecated
public void setDispatchIO(boolean dispatchIO)

Deprecated. no longer used, this has no replacement

Parameters:

dispatchIO - true to have IO operations be dispatched to Executor

setExecutor

public void setExecutor(java.util.concurrent.Executor executor)

Sets the Executor in use on the internal HttpClient

Parameters:

executor - The executor to use

setMasker

@Deprecated
public void setMasker(Masker masker)

Deprecated. not used, no replacement

Parameters:

masker - does nothing

setMaxBinaryMessageBufferSize

public void setMaxBinaryMessageBufferSize(int max)

setMaxIdleTimeout

public void setMaxIdleTimeout(long ms)

Set the max idle timeout for new connections.

Existing connections will not have their max idle timeout adjusted.

Parameters:

ms - the timeout in milliseconds

setMaxTextMessageBufferSize

public void setMaxTextMessageBufferSize(int max)

getHttpClient

public HttpClient getHttpClient()

Get the internal HttpClient.

Note: this can result in a LinkageError if used within a WebApp that runs on a server that also has HttpClient on the server classpath.

Returns:

the internal HttpClient

setStopAtShutdown

public void setStopAtShutdown(boolean stop)

Set JVM shutdown behavior.

Parameters:

stop - If true, this client instance will be explicitly stopped when the JVM is shutdown. Otherwise the application is responsible for maintaining the WebSocketClient lifecycle.

See Also:

Runtime.addShutdownHook(Thread), ShutdownThread

isStopAtShutdown

public boolean isStopAtShutdown()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class AbstractLifeCycle