Package org.glassfish.tyrus.core

Class TyrusEndpointWrapper

java.lang.Object

org.glassfish.tyrus.core.TyrusEndpointWrapper

public class TyrusEndpointWrapper
extends Object

Wraps the registered application class.

There is one TyrusEndpointWrapper for each application class, which handles all the methods.

Author:

Danny Coward, Stepan Kopriva, Martin Matula, Pavel Bucek

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TyrusEndpointWrapper.SessionListener	Session listener.

Constructor Summary

Constructors

Constructor	Description
TyrusEndpointWrapper(Endpoint endpoint, EndpointConfig configuration, ComponentProviderService componentProvider, WebSocketContainer container, String contextPath, ServerEndpointConfig.Configurator configurator, TyrusEndpointWrapper.SessionListener sessionListener, ClusterContext clusterContext, EndpointEventListener endpointEventListener, Boolean parallelBroadcastEnabled)	Create TyrusEndpointWrapper for Endpoint instance or AnnotatedEndpoint instance.
TyrusEndpointWrapper(Class<? extends Endpoint> endpointClass, EndpointConfig configuration, ComponentProviderService componentProvider, WebSocketContainer container, String contextPath, ServerEndpointConfig.Configurator configurator, TyrusEndpointWrapper.SessionListener sessionListener, ClusterContext clusterContext, EndpointEventListener endpointEventListener, Boolean parallelBroadcastEnabled)	Create TyrusEndpointWrapper for class that extends Endpoint.

Method Summary

Modifier and Type	Method	Description
Session	createSessionForRemoteEndpoint(TyrusWebSocket socket, String subprotocol, List<Extension> extensions, DebugContext debugContext)	Creates a Session based on the TyrusWebSocket, subprotocols and extensions.
Object	doEncode(Session session, Object message)
EndpointConfig	getEndpointConfig()	Get Endpoint configuration.
String	getEndpointPath()	Server-side; Get Endpoint absolute path.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

TyrusEndpointWrapper

public TyrusEndpointWrapper(Class<? extends Endpoint> endpointClass,
 EndpointConfig configuration,
 ComponentProviderService componentProvider,
 WebSocketContainer container,
 String contextPath,
 ServerEndpointConfig.Configurator configurator,
 TyrusEndpointWrapper.SessionListener sessionListener,
 ClusterContext clusterContext,
 EndpointEventListener endpointEventListener,
 Boolean parallelBroadcastEnabled)
                     throws DeploymentException

Create TyrusEndpointWrapper for class that extends Endpoint.

Parameters:

endpointClass - endpoint class for which the wrapper is created.

configuration - endpoint configuration.

componentProvider - component provider.

container - container where the wrapper is running.

contextPath - context path of the application.

configurator - endpoint configurator.

sessionListener - session listener.

clusterContext - cluster context instance. null indicates standalone mode.

endpointEventListener - endpoint event listener.

parallelBroadcastEnabled - true if parallel broadcast should be enabled, true is default.

Throws:

DeploymentException - when the endpoint is not valid.

TyrusEndpointWrapper

public TyrusEndpointWrapper(Endpoint endpoint,
 EndpointConfig configuration,
 ComponentProviderService componentProvider,
 WebSocketContainer container,
 String contextPath,
 ServerEndpointConfig.Configurator configurator,
 TyrusEndpointWrapper.SessionListener sessionListener,
 ClusterContext clusterContext,
 EndpointEventListener endpointEventListener,
 Boolean parallelBroadcastEnabled)
                     throws DeploymentException

Create TyrusEndpointWrapper for Endpoint instance or AnnotatedEndpoint instance.

Parameters:

endpoint - endpoint instance for which the wrapper is created.

configuration - endpoint configuration.

componentProvider - component provider.

container - container where the wrapper is running.

contextPath - context path of the application.

configurator - endpoint configurator.

sessionListener - session listener.

clusterContext - cluster context instance. null indicates standalone mode.

endpointEventListener - endpoint event listener.

parallelBroadcastEnabled - true if parallel broadcast should be enabled, true is default.

Throws:

DeploymentException - when the endpoint is not valid.

Method Details

doEncode

public Object doEncode(Session session,
 Object message)
                throws EncodeException,
IOException

Throws:

EncodeException

IOException

getEndpointPath

public String getEndpointPath()

Server-side; Get Endpoint absolute path.

Returns:

endpoint absolute path.

createSessionForRemoteEndpoint

public Session createSessionForRemoteEndpoint(TyrusWebSocket socket,
 String subprotocol,
 List<Extension> extensions,
 DebugContext debugContext)

Creates a Session based on the TyrusWebSocket, subprotocols and extensions.

Parameters:

socket - the other end of the connection.

subprotocol - used.

extensions - extensions used.

debugContext - debug context.

Returns:

Session representing the connection.

getEndpointConfig

public EndpointConfig getEndpointConfig()

Get Endpoint configuration.

Returns:

configuration.

toString

public String toString()

Overrides:

toString in class Object