+ sub_sock.Subscribe([]byte{}) //subscribe empty filter -> aka to all messages
+
+ if err = sub_sock.Connect(sub_port); err != nil {
+ panic(err)
+ }
+
+ sub_chans = sub_sock.ChannelsBuffer(10)
+ go zmqsHandleError(sub_chans)
+ } else {
+ sub_chans = nil
+ }