-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()