add debug and error event listening options

src/main/java/com/exaroton/api/ws/DebugListener.java

@@ -0,0 +1,5 @@
+package com.exaroton.api.ws;
+
+public interface DebugListener {
+    public void onDebug(String message);
+}

src/main/java/com/exaroton/api/ws/ErrorListener.java

@@ -0,0 +1,5 @@
+package com.exaroton.api.ws;
+
+public interface ErrorListener {
+    public void onError(String error, Throwable t);
+}

src/main/java/com/exaroton/api/ws/WebSocketClient.java

@@ -30,6 +30,7 @@ public WebSocketClient(URI uri, WebSocketManager manager) {
 
     @Override
     public void onOpen(ServerHandshake handshakedata) {
+        manager.sendDebug("Websocket opened with status " + handshakedata.getHttpStatus() + ": " + handshakedata.getHttpStatusMessage());
         manager.handleOpen();
     }
 
@@ -51,10 +52,12 @@ public void onMessage(String message) {
     @Override
     public void onError(Exception ex) {
         logger.error("A websocket error ocurred", ex);
+        manager.onError("A websocket error ocurred: " + ex.getMessage(), ex);
     }
 
     @Override
     public void onClose(int code, String reason, boolean remote) {
+        manager.sendDebug("Websocket closed with code " + code + ": " + reason);
         manager.handleClose(code, reason, remote);
     }
 }

src/main/java/com/exaroton/api/ws/WebSocketManager.java

@@ -38,6 +38,10 @@ public class WebSocketManager {
      */
     private final Server server;
 
+    private ErrorListener errorListener = null;
+
+    private DebugListener debugListener = null;
+
     public WebSocketManager(String uri, String apiToken, Server server) {
         try {
             URI u = new URI(uri);
@@ -302,4 +306,39 @@ public boolean serverHasStatus(int... status) {
         }
         return this.server.hasStatus(status);
     }
+
+    /**
+     * Listen to websocket errors
+     * @param errorListener the only error listener
+     */
+    public void setErrorListener(ErrorListener errorListener) {
+        this.errorListener = errorListener;
+    }
+
+    /**
+     * listen to websocket debug information
+     * @param debugListener the only debug listener
+     */
+    public void setDebugListener(DebugListener debugListener) {
+        this.debugListener = debugListener;
+    }
+
+
+    /**
+     * send debug information to listeners
+     */
+    void sendDebug(String message) {
+        if (this.debugListener != null) {
+            this.debugListener.onDebug(message);
+        }
+    }
+
+    /**
+     * send error to listeners
+     */
+    void onError(String error, Throwable throwable) {
+        this.errorListener.onError(error, throwable);
+    }
+
+
 }

src/main/java/com/exaroton/api/ws/stream/ConsoleStream.java

@@ -1,7 +1,6 @@
 package com.exaroton.api.ws.stream;
 
 import com.exaroton.api.ws.WebSocketManager;
-import com.exaroton.api.ws.subscriber.ConsoleSubscriber;
 
 public class ConsoleStream extends Stream {
 

src/main/java/com/exaroton/api/ws/stream/HeapStream.java

@@ -1,7 +1,6 @@
 package com.exaroton.api.ws.stream;
 
 import com.exaroton.api.ws.WebSocketManager;
-import com.exaroton.api.ws.subscriber.HeapSubscriber;
 
 public class HeapStream extends Stream {
 

src/main/java/com/exaroton/api/ws/stream/ServerStatusStream.java

@@ -2,7 +2,6 @@
 
 
 import com.exaroton.api.ws.WebSocketManager;
-import com.exaroton.api.ws.subscriber.ServerStatusSubscriber;
 
 public class ServerStatusStream extends Stream {
 

src/main/java/com/exaroton/api/ws/stream/StatsStream.java

@@ -1,7 +1,6 @@
 package com.exaroton.api.ws.stream;
 
 import com.exaroton.api.ws.WebSocketManager;
-import com.exaroton.api.ws.subscriber.StatsSubscriber;
 
 public class StatsStream extends Stream {
 

src/main/java/com/exaroton/api/ws/stream/TickStream.java

@@ -1,7 +1,6 @@
 package com.exaroton.api.ws.stream;
 
 import com.exaroton.api.ws.WebSocketManager;
-import com.exaroton.api.ws.subscriber.TickSubscriber;
 
 public class TickStream extends Stream {