diff --git a/src/main/kotlin/io/polygon/kotlin/sdk/Version.kt b/src/main/kotlin/io/polygon/kotlin/sdk/Version.kt
index e67606d..92c58e0 100644
--- a/src/main/kotlin/io/polygon/kotlin/sdk/Version.kt
+++ b/src/main/kotlin/io/polygon/kotlin/sdk/Version.kt
@@ -1,6 +1,6 @@
 package io.polygon.kotlin.sdk
 
 object Version {
-    const val name = "v5.1.1"
+    const val name = "v5.1.2"
     const val userAgent = "Polygon.io JVM Client/$name"
 }
diff --git a/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketClient.kt b/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketClient.kt
index c527a75..e898b04 100644
--- a/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketClient.kt
+++ b/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketClient.kt
@@ -275,6 +275,7 @@ constructor(
                         Market.BusinessCrypto -> parseBusinessMessage(frame)
                         is Market.Other -> parseOtherMessage(frame)
                     }
+            collector.add(message)
         }
 
         return collector