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=ea9b0e5a42b1a0dcf988e22b4cbd32dc905a8c09;hb=837698930d5eea7c100a1233ee1d92e71896bb5d;hp=94d8996a623a4a29cfb4a06e18d45ce19bd3b8b9;hpb=ab419f6917d5bf30dd6557902ee01b3c529c89f0;p=svn42.git diff --git a/go/r3-eventbroker_zmq/sockettoevent.go b/go/r3-eventbroker_zmq/sockettoevent.go index 94d8996..ea9b0e5 100644 --- a/go/r3-eventbroker_zmq/sockettoevent.go +++ b/go/r3-eventbroker_zmq/sockettoevent.go @@ -7,11 +7,9 @@ import ( "strconv" "time" //~ "./brain" - "encoding/json" pubsub "github.com/tuxychandru/pubsub" zmq "github.com/vaughan0/go-zmq" "log" - "fmt" ) var ( @@ -142,18 +140,6 @@ func MakeTimeTick(ps *pubsub.PubSub) { ps.Pub(TimeTick{time.Now().Unix()},"time") } -func FormatEventForSocket(event_interface interface{}) (data [][]byte, err error) { - var msg []byte - fmt.Printf("%T%+v\n", event_interface, event_interface) - msg, err = json.Marshal(event_interface) - if err != nil { - return - } - etype := []byte(fmt.Sprintf("%T", event_interface)[5:]) - data = [][]byte{etype, msg} - return -} - //~ match_presence := re_presence_.FindStringSubmatch(line) //~ match_status := re_status_.FindStringSubmatch(line) //~ match_command := re_command_.FindStringSubmatch(line)