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 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

  • 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)