context cleanup and subscribe, but still heavily broken
[svn42.git] / go / door_daemon_zmq / main.go
index 0ff877c..52e8197 100644 (file)
@@ -44,7 +44,10 @@ func main() {
         os.Exit(1);
     }
 
-    cmd_chans, pub_chans := ZmqsInit(cmd_port_, pub_port_)
+    zmqctx, cmd_chans, pub_chans := ZmqsInit(cmd_port_, pub_port_)
+    defer cmd_chans.Close()
+    defer pub_chans.Close()
+    defer zmqctx.Close()
 
     serial_wr, err := OpenAndHandleSerial(args[0], pub_chans.Out())
     defer close(serial_wr)