X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fdoor_client_zmq%2Fmain.go;h=60f2fc9772d2253e5151c9803175d8a8efe157b2;hb=12108d50886717b2f58e3c1f4be52b078c790449;hp=f63a0ee817248dd8f7edc396bdeb645e1e022318;hpb=e021d7de474ab4755e8081e3009c328fd7d07c09;p=svn42.git diff --git a/go/door_client_zmq/main.go b/go/door_client_zmq/main.go index f63a0ee..60f2fc9 100644 --- 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() } @@ -80,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)) } } }