+func ConnectSerialToZMQ(pub_sock *zmq.Socket) {
+ defer func() {
+ if x:= recover(); x != nil { Syslog_.Println(x) }
+ }()
+
+ serial_wr, serial_rd, err := OpenAndHandleSerial(tty_dev_, serial_speed_)
+ if err != nil { panic(err) }
+ defer close(serial_wr)
+
+ for incoming_ser_line := range(serial_rd) {
+ Syslog_.Printf("%s",incoming_ser_line)
+ if err := pub_sock.Send(incoming_ser_line); err != nil { Syslog_.Println(err.Error()) }
+ }
+}
+