X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fdoor_client_zmq%2Fzeromq.go;h=4b3b87d25eecb430989492beb5f2ec81dc634d11;hb=05f5975f0266e628e89cf0f60f84f47d43136747;hp=b74ca5eca32a34599ec6616fcddb811908a83de4;hpb=342b4f2bf36cb16ff48cb894a80ffd8eac734086;p=svn42.git diff --git a/go/door_client_zmq/zeromq.go b/go/door_client_zmq/zeromq.go index b74ca5e..4b3b87d 100644 --- a/go/door_client_zmq/zeromq.go +++ b/go/door_client_zmq/zeromq.go @@ -16,13 +16,13 @@ func ZmqsInit(cmd_port, sub_port string) (cmd_chans, pub_chans *zmq.Channels) { } //close only on panic, otherwise leave open: defer func(){ if r:= recover(); r != nil { cmd_ctx.Close(); panic(r) } }() - + pub_ctx, err := zmq.NewContext() if err != nil { panic(err) } defer func() { if r:= recover(); r != nil { pub_ctx.Close(); panic(r) } }() - + cmd_sock, err := cmd_ctx.Socket(zmq.Req) if err != nil { panic(err) @@ -42,7 +42,7 @@ func ZmqsInit(cmd_port, sub_port string) (cmd_chans, pub_chans *zmq.Channels) { if err = pub_sock.Bind(sub_port); err != nil { panic(err) } - + cmd_chans = cmd_sock.Channels() pub_chans = cmd_sock.Channels() go zmqsHandleError(cmd_chans, pub_chans)