Class JettyWebSocketAdapter

  • All Implemented Interfaces:
    WebSocketAdapter

    public abstract class JettyWebSocketAdapter
    extends java.lang.Object
    implements WebSocketAdapter
    Jetty based impl of the WebSocketAdapter.
    • Field Detail

      • clientLock_

        private final java.lang.Object clientLock_
      • client_

        private org.eclipse.jetty.websocket.client.WebSocketClient client_
      • incomingSession_

        private volatile org.eclipse.jetty.websocket.api.Session incomingSession_
      • outgoingSession_

        private org.eclipse.jetty.websocket.api.Session outgoingSession_
    • Constructor Detail

      • JettyWebSocketAdapter

        public JettyWebSocketAdapter​(WebClient webClient)
    • Method Detail

      • start

        public void start()
                   throws java.lang.Exception
        Specified by:
        start in interface WebSocketAdapter
        Throws:
        java.lang.Exception
      • connect

        public void connect​(java.net.URI url)
                     throws java.lang.Exception
        Specified by:
        connect in interface WebSocketAdapter
        Throws:
        java.lang.Exception
      • send

        public void send​(java.lang.Object content)
                  throws java.io.IOException
        Specified by:
        send in interface WebSocketAdapter
        Throws:
        java.io.IOException
      • closeClient

        public void closeClient()
                         throws java.lang.Exception
        Specified by:
        closeClient in interface WebSocketAdapter
        Throws:
        java.lang.Exception