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=cde60c9ee06c644ba81cbc0264ecdaa83cdfaab3;hb=12108d50886717b2f58e3c1f4be52b078c790449;hp=abf17b21f333597987dc41acca03bf102c7929bf;hpb=fbf2f6904c7f8f06cb46bc9a4e8462c95b42119d;p=svn42.git diff --git a/go/door_client_zmq/zeromq.go b/go/door_client_zmq/zeromq.go index abf17b2..cde60c9 100644 --- a/go/door_client_zmq/zeromq.go +++ b/go/door_client_zmq/zeromq.go @@ -45,11 +45,7 @@ func ZmqsInit(cmd_port, sub_port string) (ctx *zmq.Context, cmd_chans, sub_chan } defer func() { if r:= recover(); r != nil { sub_sock.Close(); panic(r) } }() - sub_sock.Subscribe([]byte("close")) - sub_sock.Subscribe([]byte("toggle")) - sub_sock.Subscribe([]byte("Info")) - sub_sock.Subscribe([]byte("State")) - sub_sock.Subscribe([]byte("open")) + sub_sock.Subscribe([]byte{}) //subscribe empty filter -> aka to all messages if err = sub_sock.Connect(sub_port); err != nil { panic(err)