Class JsrEvents<T extends Annotation, C extends javax.websocket.EndpointConfig>

java.lang.Object

org.eclipse.jetty.websocket.jsr356.annotations.JsrEvents<T,C>

Type Parameters:

T - the annotation type

C - the endpoint config type

public class JsrEvents<T extends Annotation, C extends javax.websocket.EndpointConfig>
extends Object

The live event methods found for a specific Annotated Endpoint

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.eclipse.jetty.util.log.Logger	LOG
private final AnnotatedEndpointMetadata<T,C>	metadata
private final OnMessageBinaryCallable	onBinary	Callable for @OnMessage annotation dealing with Binary Message Format
private final OnMessageBinaryStreamCallable	onBinaryStream	Callable for @OnMessage annotation dealing with Binary Streaming Message Format
private final OnCloseCallable	onClose	Callable for @OnClose annotation
private final OnErrorCallable	onError	Callable for @OnError annotation
private final OnOpenCallable	onOpen	Callable for @OnOpen annotation.
private OnMessagePongCallable	onPong	Callable for @OnMessage annotation dealing with Pong Message Format
private final OnMessageTextCallable	onText	Callable for @OnMessage annotation dealing with Text Message Format
private final OnMessageTextStreamCallable	onTextStream	Callable for @OnMessage annotation dealing with Text Streaming Message Format
private Map<String,String>	pathParameters	The Request Parameters (from resolved javax.websocket.server.PathParam entries)

Constructor Summary

Constructors

Constructor	Description
JsrEvents(AnnotatedEndpointMetadata<T,C> metadata)

Method Summary

Modifier and Type	Method	Description
void	callBinary(javax.websocket.RemoteEndpoint.Async endpoint, Object websocket, ByteBuffer buf, boolean fin)
void	callBinaryStream(javax.websocket.RemoteEndpoint.Async endpoint, Object websocket, InputStream stream)
void	callClose(Object websocket, javax.websocket.CloseReason close)
void	callError(Object websocket, Throwable cause)
void	callOpen(Object websocket, javax.websocket.EndpointConfig config)
void	callPong(javax.websocket.RemoteEndpoint.Async endpoint, Object websocket, ByteBuffer pong)
void	callText(javax.websocket.RemoteEndpoint.Async endpoint, Object websocket, String text, boolean fin)
void	callTextStream(javax.websocket.RemoteEndpoint.Async endpoint, Object websocket, Reader reader)
AnnotatedEndpointMetadata<T,C>	getMetadata()
boolean	hasBinary()
boolean	hasBinaryStream()
boolean	hasText()
boolean	hasTextStream()
void	init(JsrSession session)
boolean	isBinaryPartialSupported()
boolean	isTextPartialSupported()
void	setPathParameters(Map<String,String> pathParameters)

Methods inherited from class Object

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

Field Details

LOG

private static final org.eclipse.jetty.util.log.Logger LOG

metadata

private final AnnotatedEndpointMetadata<T extends Annotation, C extends javax.websocket.EndpointConfig> metadata

onOpen

private final OnOpenCallable onOpen

Callable for @OnOpen annotation.

onClose

private final OnCloseCallable onClose

Callable for @OnClose annotation

onError

private final OnErrorCallable onError

Callable for @OnError annotation

onText

private final OnMessageTextCallable onText

Callable for @OnMessage annotation dealing with Text Message Format

onTextStream

private final OnMessageTextStreamCallable onTextStream

Callable for @OnMessage annotation dealing with Text Streaming Message Format

onBinary

private final OnMessageBinaryCallable onBinary

Callable for @OnMessage annotation dealing with Binary Message Format

onBinaryStream

private final OnMessageBinaryStreamCallable onBinaryStream

Callable for @OnMessage annotation dealing with Binary Streaming Message Format

onPong

private OnMessagePongCallable onPong

Callable for @OnMessage annotation dealing with Pong Message Format

pathParameters

private Map<String,String> pathParameters

The Request Parameters (from resolved javax.websocket.server.PathParam entries)

Constructor Details

JsrEvents

public JsrEvents(AnnotatedEndpointMetadata<T,C> metadata)

Method Details

callBinary

public void callBinary(javax.websocket.RemoteEndpoint.Async endpoint,
 Object websocket,
 ByteBuffer buf,
 boolean fin)
                throws javax.websocket.DecodeException

Throws:

javax.websocket.DecodeException

callBinaryStream

public void callBinaryStream(javax.websocket.RemoteEndpoint.Async endpoint,
 Object websocket,
 InputStream stream)
                      throws javax.websocket.DecodeException,
IOException

Throws:

javax.websocket.DecodeException

IOException

callClose

public void callClose(Object websocket,
 javax.websocket.CloseReason close)

callError

public void callError(Object websocket,
 Throwable cause)

callOpen

public void callOpen(Object websocket,
 javax.websocket.EndpointConfig config)

callPong

public void callPong(javax.websocket.RemoteEndpoint.Async endpoint,
 Object websocket,
 ByteBuffer pong)

callText

public void callText(javax.websocket.RemoteEndpoint.Async endpoint,
 Object websocket,
 String text,
 boolean fin)
              throws javax.websocket.DecodeException

Throws:

javax.websocket.DecodeException

callTextStream

public void callTextStream(javax.websocket.RemoteEndpoint.Async endpoint,
 Object websocket,
 Reader reader)
                    throws javax.websocket.DecodeException,
IOException

Throws:

javax.websocket.DecodeException

IOException

getMetadata

public AnnotatedEndpointMetadata<T,C> getMetadata()

hasBinary

public boolean hasBinary()

hasBinaryStream

public boolean hasBinaryStream()

hasText

public boolean hasText()

hasTextStream

public boolean hasTextStream()

init

public void init(JsrSession session)

isBinaryPartialSupported

public boolean isBinaryPartialSupported()

isTextPartialSupported

public boolean isTextPartialSupported()

setPathParameters

public void setPathParameters(Map<String,String> pathParameters)