minor improvements

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

diff --git a/go/door_client_zmq/main.go b/go/door_client_zmq/main.go
index 193c643..60f2fc9 100644 (file)
--- a/go/door_client_zmq/main.go
+++ b/go/door_client_zmq/main.go
@@ -25,8 +25,8 @@ func usage() {
 }
 
 func init() {
-    flag.StringVar(&cmd_port_, "cmdport", "tcp://127.0.0.1:3232", "zmq command socket path")
-    flag.StringVar(&sub_port_, "pubport", "pgm://233.252.1.42:4242", "zmq subscribe/listen socket path")
+    flag.StringVar(&cmd_port_, "cmdport", "ipc:///run/tuer/door_cmd.ipc", "zmq command socket path")
+    flag.StringVar(&sub_port_, "pubport", "tcp://torwaechter.realraum.at:4242", "zmq subscribe/listen socket path")
     flag.Usage = usage
     flag.Parse()
 }
@@ -55,9 +55,10 @@ func ByteArrayToString(bb [][]byte) string {
 }
 
 func main() {
-    cmd_chans, sub_chans := ZmqsInit(cmd_port_, sub_port_)
+    zmqctx, cmd_chans, sub_chans := ZmqsInit(cmd_port_, sub_port_)
     defer cmd_chans.Close()
     defer sub_chans.Close()
+    defer zmqctx.Close()
     var listen bool
     var ignore_next bool
 
@@ -79,23 +80,20 @@ func main() {
                     default:
                         ignore_next = true
                         cmd_chans.Out() <- input
-                        log.Print("input sent")
                         reply := <- cmd_chans.In()
-                        log.Print("reply received")
                         fmt.Println(ByteArrayToString(reply))
                 }
             } else {
                 os.Exit(0)
             }
         case pubsubstuff := <- sub_chans.In():
-            log.Print("pubsubstuff",pubsubstuff)
             if len(pubsubstuff) == 0 { continue}
             if ignore_next {
                 ignore_next = false
                 continue
             }
             if listen {
-                fmt.Println(pubsubstuff)
+                fmt.Println(ByteArrayToString(pubsubstuff))
             }
         }
     }