code: @Override
    public void run()
    {
      boolean isValid = false;
        
      try {
        _socket.getChannel().configureBlocking(true);
        /*
        EndpointReaderWebSocket wsEndpointReader = _client.getEndpointReader();
        
        do {
          if (! wsEndpointReader.onRead()) {
            return;
          }
        } while (wsEndpointReader.isReadAvailable() && ! _client.isClosed());
        
        isValid = ! _client.isClosed();
        
        if (isValid) {
          registerKeepalive();
        }
        */
      } catch (Exception e) {
        e.printStackTrace();
        log.log(Level.WARNING, e.toString(), e);
      } finally {
        if (! isValid) {
          _client.close();
        }
      }
    }
docs: /*
  @Override
  public QSocket socket()
  {
  return _qSocket;
  }