diff --git a/data-api/java-websocket/pom.xml b/data-api/java-websocket/pom.xml
index f647e87de9..be518c8762 100644
--- a/data-api/java-websocket/pom.xml
+++ b/data-api/java-websocket/pom.xml
@@ -4,7 +4,7 @@
 
     <groupId>io.coinapi.websocket</groupId>
     <artifactId>v1</artifactId>
-    <version>1.5</version>
+    <version>1.6</version>
 
     <organization>
         <name>COINAPI LTD</name>
diff --git a/data-api/java-websocket/src/main/java/io/coinapi/websocket/CoinAPIWebSocketImpl.java b/data-api/java-websocket/src/main/java/io/coinapi/websocket/CoinAPIWebSocketImpl.java
index 30675d5e19..58351b3016 100644
--- a/data-api/java-websocket/src/main/java/io/coinapi/websocket/CoinAPIWebSocketImpl.java
+++ b/data-api/java-websocket/src/main/java/io/coinapi/websocket/CoinAPIWebSocketImpl.java
@@ -213,21 +213,25 @@ public void setVolumeInvoke(InvokeFunction function) {
      * @param function
      */
     @Override
-    public void setErrorInvoke(InvokeFunction function) { this.errorInvoke = function; }
+    public void setErrorInvoke(InvokeFunction function) { 
+        this.errorInvoke = function; 
+    }
 
     /**
      *
      * @param function
      */
     @Override
-    public void setReconnectInvoke(InvokeFunction function) { this.reconnectInvoke = function; }
+    public void setReconnectInvoke(InvokeFunction function) { 
+        this.reconnectInvoke = function; 
+    }
 
     private void handle(String message, Class deserializeClass, InvokeFunction invokeFunction) throws IOException, NotImplementedException {
 
         Object deserialize = json.deserialize(deserializeClass, new ByteArrayInputStream(message.getBytes()));
 
         if (invokeFunction == null) {
-            throw new NotImplementedException();
+            return;
         }
         invokeFunction.preprocesMessages((MessageBase) deserialize);
     }