T
- the annotation typeC
- the endpoint config typepublic class JsrEvents<T extends java.lang.annotation.Annotation,C extends javax.websocket.EndpointConfig>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private static Logger |
LOG |
private AnnotatedEndpointMetadata<T,C> |
metadata |
private OnMessageBinaryCallable |
onBinary
Callable for @
OnMessage annotation dealing with Binary Message Format |
private OnMessageBinaryStreamCallable |
onBinaryStream
Callable for @
OnMessage annotation dealing with Binary Streaming Message Format |
private OnCloseCallable |
onClose
Callable for @
OnClose annotation |
private OnErrorCallable |
onError
Callable for @
OnError annotation |
private OnOpenCallable |
onOpen
Callable for @
OnOpen annotation. |
private OnMessagePongCallable |
onPong
Callable for @
OnMessage annotation dealing with Pong Message Format |
private OnMessageTextCallable |
onText
Callable for @
OnMessage annotation dealing with Text Message Format |
private OnMessageTextStreamCallable |
onTextStream
Callable for @
OnMessage annotation dealing with Text Streaming Message Format |
private java.util.Map<java.lang.String,java.lang.String> |
pathParameters
The Request Parameters (from resolved javax.websocket.server.PathParam entries)
|
Constructor and Description |
---|
JsrEvents(AnnotatedEndpointMetadata<T,C> metadata) |
Modifier and Type | Method and Description |
---|---|
void |
callBinary(javax.websocket.RemoteEndpoint.Async endpoint,
java.lang.Object websocket,
java.nio.ByteBuffer buf,
boolean fin) |
void |
callBinaryStream(javax.websocket.RemoteEndpoint.Async endpoint,
java.lang.Object websocket,
java.io.InputStream stream) |
void |
callClose(java.lang.Object websocket,
javax.websocket.CloseReason close) |
void |
callError(java.lang.Object websocket,
java.lang.Throwable cause) |
void |
callOpen(java.lang.Object websocket,
javax.websocket.EndpointConfig config) |
void |
callPong(javax.websocket.RemoteEndpoint.Async endpoint,
java.lang.Object websocket,
java.nio.ByteBuffer pong) |
void |
callText(javax.websocket.RemoteEndpoint.Async endpoint,
java.lang.Object websocket,
java.lang.String text,
boolean fin) |
void |
callTextStream(javax.websocket.RemoteEndpoint.Async endpoint,
java.lang.Object websocket,
java.io.Reader reader) |
AnnotatedEndpointMetadata<T,C> |
getMetadata() |
boolean |
hasBinary() |
boolean |
hasBinaryStream() |
boolean |
hasText() |
boolean |
hasTextStream() |
void |
init(JsrSession session) |
boolean |
isBinaryPartialSupported() |
boolean |
isTextPartialSupported() |
void |
setPathParameters(java.util.Map<java.lang.String,java.lang.String> pathParameters) |
private static final Logger LOG
private final AnnotatedEndpointMetadata<T extends java.lang.annotation.Annotation,C extends javax.websocket.EndpointConfig> metadata
private final OnOpenCallable onOpen
OnOpen
annotation.private final OnCloseCallable onClose
OnClose
annotationprivate final OnErrorCallable onError
OnError
annotationprivate final OnMessageTextCallable onText
OnMessage
annotation dealing with Text Message Formatprivate final OnMessageTextStreamCallable onTextStream
OnMessage
annotation dealing with Text Streaming Message Formatprivate final OnMessageBinaryCallable onBinary
OnMessage
annotation dealing with Binary Message Formatprivate final OnMessageBinaryStreamCallable onBinaryStream
OnMessage
annotation dealing with Binary Streaming Message Formatprivate OnMessagePongCallable onPong
OnMessage
annotation dealing with Pong Message Formatprivate java.util.Map<java.lang.String,java.lang.String> pathParameters
public JsrEvents(AnnotatedEndpointMetadata<T,C> metadata)
public void callBinary(javax.websocket.RemoteEndpoint.Async endpoint, java.lang.Object websocket, java.nio.ByteBuffer buf, boolean fin) throws javax.websocket.DecodeException
javax.websocket.DecodeException
public void callBinaryStream(javax.websocket.RemoteEndpoint.Async endpoint, java.lang.Object websocket, java.io.InputStream stream) throws javax.websocket.DecodeException, java.io.IOException
javax.websocket.DecodeException
java.io.IOException
public void callClose(java.lang.Object websocket, javax.websocket.CloseReason close)
public void callError(java.lang.Object websocket, java.lang.Throwable cause)
public void callOpen(java.lang.Object websocket, javax.websocket.EndpointConfig config)
public void callPong(javax.websocket.RemoteEndpoint.Async endpoint, java.lang.Object websocket, java.nio.ByteBuffer pong)
public void callText(javax.websocket.RemoteEndpoint.Async endpoint, java.lang.Object websocket, java.lang.String text, boolean fin) throws javax.websocket.DecodeException
javax.websocket.DecodeException
public void callTextStream(javax.websocket.RemoteEndpoint.Async endpoint, java.lang.Object websocket, java.io.Reader reader) throws javax.websocket.DecodeException, java.io.IOException
javax.websocket.DecodeException
java.io.IOException
public AnnotatedEndpointMetadata<T,C> getMetadata()
public boolean hasBinary()
public boolean hasBinaryStream()
public boolean hasText()
public boolean hasTextStream()
public void init(JsrSession session)
public boolean isBinaryPartialSupported()
public boolean isTextPartialSupported()
public void setPathParameters(java.util.Map<java.lang.String,java.lang.String> pathParameters)