diff --git a/packages/broker/package.json b/packages/broker/package.json
index b143be2..22f1ac8 100644
--- a/packages/broker/package.json
+++ b/packages/broker/package.json
@@ -15,7 +15,8 @@
     "@syndicate-lang/driver-browser-ui": "^0.0.12",
     "@syndicate-lang/driver-http-node": "^0.0.11",
     "@syndicate-lang/driver-tcp-node": "^0.0.1",
-    "@syndicate-lang/driver-timer": "^0.0.15"
+    "@syndicate-lang/driver-timer": "^0.0.15",
+    "preserves": "^0.0.0"
   },
   "scripts": {
     "prepare": "which redo >/dev/null && redo || ../../do"
diff --git a/packages/broker/src/index.js b/packages/broker/src/index.js
index 21500db..12b29da 100644
--- a/packages/broker/src/index.js
+++ b/packages/broker/src/index.js
@@ -14,6 +14,9 @@ spawn named 'serverLogger' {
   on asserted Http.Request(_, server, $method, $path, $query, $req) {
     console.log(method, path.toJS(), query.toJS());
   }
+  on asserted Http.WebSocket(_, server, $path, $query) {
+    console.log(path.toJS(), query.toJS());
+  }
 }
 
 spawn named 'rootServer' {
@@ -31,7 +34,7 @@ spawn named 'rootServer' {
 spawn named 'websocketListener' {
   during Http.WebSocket($reqId, server, ['broker'], _) spawn named ['wsConnection', reqId] {
     on message Http.DataIn(reqId, $message) {
-      console.log('got', reqId, message);
+      console.log('got', reqId, new (require('preserves').Decoder)(message).next())
       ^ Http.DataOut(reqId, message);
     }