X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fr3-eventbroker_zmq%2Fsockettoevent.go;fp=go%2Fr3-eventbroker_zmq%2Fsockettoevent.go;h=fbd74d5759445010a5148eb3f90f173bedf0feb9;hb=0d2bd96d2c019a7c0e0282898809fb03962ca701;hp=6511ff03e91090cae201cb24d6c7404115d20f40;hpb=a8e0651d52192d208758ae9a59e21af313685da4;p=svn42.git diff --git a/go/r3-eventbroker_zmq/sockettoevent.go b/go/r3-eventbroker_zmq/sockettoevent.go index 6511ff0..fbd74d5 100644 --- a/go/r3-eventbroker_zmq/sockettoevent.go +++ b/go/r3-eventbroker_zmq/sockettoevent.go @@ -9,7 +9,6 @@ import ( //~ "./brain" pubsub "github.com/tuxychandru/pubsub" zmq "github.com/vaughan0/go-zmq" - "log" "./r3events" ) @@ -41,7 +40,7 @@ func parseSocketInputLine_State(lines [][]byte, ps *pubsub.PubSub, ts int64) { case "opening": case "closing": default: - if Syslog_ != nil {Syslog_.Print("parseSocketInputLine_State: Unexpected State:", lines)} + Syslog_.Print("parseSocketInputLine_State: Unexpected State:", lines) } } @@ -49,7 +48,7 @@ func parseSocketInputLine_State(lines [][]byte, ps *pubsub.PubSub, ts int64) { func ParseSocketInputLine(lines [][]byte, ps *pubsub.PubSub, keylookup_socket *zmq.Socket) { //, brn *brain.Brain) { ts := time.Now().Unix() if len(lines) < 1 { return } - log.Printf("ParseSocketInputLine: %s %s",string(lines[0]), lines[1:]) + Debug_.Printf("ParseSocketInputLine: %s %s",string(lines[0]), lines[1:]) switch string(lines[0]) { case "State:": if len(lines) < 2 { return }