+
+ zmqctx, sub_in_chans, pub_out_socket, keylookup_socket := ZmqsInit(doorsub_addr_, sensorssub_port_, pub_port_, keylookup_addr_)
+ if sub_in_chans != nil {defer sub_in_chans.Close()}
+ defer zmqctx.Close()
+ if pub_out_socket != nil {defer pub_out_socket.Close()}
+ if keylookup_socket != nil {defer keylookup_socket.Close()}
+ if sub_in_chans == nil || pub_out_socket == nil || keylookup_socket == nil {
+ panic("zmq sockets must not be nil !!")
+ }
+
+ ps := pubsub.New(10)
+ defer ps.Shutdown() // ps.Shutdown should be called before zmq_ctx.Close(), since it will cause goroutines to shutdown and close zqm_sockets which is needed for zmq_ctx.Close() to return