public class WebSocketConnectionHandler extends AbstractReceiveListener implements WebSocketConnectionCallback {

  @Override
  public void onConnect(WebSocketHttpExchange exchange, WebSocketChannel webSocketChannel) {
    System.out.println("onConnect");
    webSocketChannel.getReceiveSetter().set(this);
    webSocketChannel.resumeReceives();
    webSocketChannel.addCloseTask(channel -> {
      System.out.println("Closing");
    });
  }

  @Override
  protected void onFullTextMessage(WebSocketChannel channel, BufferedTextMessage message) {
    System.out.println("onFullTextMessage");
    super.onFullTexMessage(channel, message);
  }

  @Override
  protected void onError(WebSocketChannel channel, Throwable error) {
    System.out.println("error");
    super.onError(channel, error);
  }

  @Override
  protected void onClose(WebSocketChannel webSocketChannel, StreamSourceFrameChannel channel)
      throws IOException {
    System.out.println("onClose");
    super.onClose(webSocketChannel, channel);
  }

  @Override
  protected void onFullCloseMessage(WebSocketChannel channel, BufferedBinaryMessage message)
      throws IOException {
    System.out.println("onFullCloseMessage");
    super.onFullCloseMessage(channel, message);
  }

  @Override
  protected void onCloseMessage(CloseMessage cm, WebSocketChannel channel) {
    System.out.println("onCloseMessage");
    super.onCloseMessage(cm, channel);
  }
}