Class WebsocketEndpoint

java.lang.Object
jakarta.websocket.Endpoint
io.fluxzero.proxy.WebsocketEndpoint
public class WebsocketEndpoint extends jakarta.websocket.Endpoint

  • Constructor Details

    • WebsocketEndpoint

      public WebsocketEndpoint(Client client)

  • Method Details

    • onOpen

      public void onOpen(jakarta.websocket.Session session, jakarta.websocket.EndpointConfig config)
      Specified by:
      onOpen in class jakarta.websocket.Endpoint

    • onClose

      public void onClose(jakarta.websocket.Session session, jakarta.websocket.CloseReason closeReason)
      Overrides:
      onClose in class jakarta.websocket.Endpoint

    • onError

      public void onError(jakarta.websocket.Session session, Throwable error)
      Overrides:
      onError in class jakarta.websocket.Endpoint

    • sendRequest

      protected void sendRequest(jakarta.websocket.Session session, String method, byte[] payload)

    • handleResultMessages

      protected void handleResultMessages(List<SerializedMessage> resultMessages)

    • handleDisconnects

      protected void handleDisconnects(List<SerializedMessage> resultMessages)

    • getContext

      protected WebsocketEndpoint.SessionContext getContext(jakarta.websocket.Session session)

    • ensureStarted

      protected void ensureStarted()

    • shutDown

      public void shutDown()