class WebSocketClient extends org.java_websocket.client.WebSocketClient {

    @Override
    public void onMessage(String s) {
        try {
            log.debug("Received message {} from server {}", s, uri);
            listener.onMessage(s);
        } catch (Exception e) {
            log.error("Failed to process message '{}' from server {}", s, uri);
        }
    }

    public  WebSocketClient(URI serverUri);
    public  WebSocketClient(URI serverUri, Map<String,String> httpHeaders);

}