context cleanup and subscribe, but still heavily broken

[svn42.git] / go / door_client_zmq / zeromq.go

diff --git a/go/door_client_zmq/zeromq.go b/go/door_client_zmq/zeromq.go
index 485e3f2..c91b7bd 100644 (file)
--- a/go/door_client_zmq/zeromq.go
+++ b/go/door_client_zmq/zeromq.go
@@ -9,9 +9,10 @@ import (
 
 // ---------- ZeroMQ Code -------------
 
-func ZmqsInit(cmd_port, sub_port string)  (cmd_chans, sub_chans *zmq.Channels) {
-
-    ctx, err := zmq.NewContext()
+func ZmqsInit(cmd_port, sub_port string)  (ctx *zmq.Context, cmd_chans, sub_chans *zmq.Channels) {
+    var subfilter []byte
+    var err error
+    ctx, err = zmq.NewContext()
     if err != nil {
         panic(err)
     }
@@ -37,6 +38,8 @@ func ZmqsInit(cmd_port, sub_port string)  (cmd_chans, sub_chans *zmq.Channels) {
         panic(err)
     }
 
+    sub_sock.Subscribe(subfilter)
+
     if err = sub_sock.Connect(sub_port); err != nil {
         panic(err)
     }