X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fdoor_client_zmq%2Fzeromq.go;fp=go%2Fdoor_client_zmq%2Fzeromq.go;h=c91b7bd6cbc581eda4944f1fe1615c4d5ecbf463;hb=e021d7de474ab4755e8081e3009c328fd7d07c09;hp=485e3f280074ce7e4a30a1965e082dd340ab6f19;hpb=02dbcb404955284e9849d80ea56e9c5e02534d40;p=svn42.git

diff --git a/go/door_client_zmq/zeromq.go b/go/door_client_zmq/zeromq.go
index 485e3f2..c91b7bd 100644
--- 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)
     }