X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fr3-eventbroker_zmq%2Fmain.go;h=aaaf8bd33ff3b7e4cd8426d095cfb82679ebab5a;hb=417e9a91ef92b248513da9f2be83519d37c599e7;hp=0e8f3de353db05bb37b07773bbdc01fc054f0270;hpb=837698930d5eea7c100a1233ee1d92e71896bb5d;p=svn42.git

diff --git a/go/r3-eventbroker_zmq/main.go b/go/r3-eventbroker_zmq/main.go
index 0e8f3de..aaaf8bd 100644
--- a/go/r3-eventbroker_zmq/main.go
+++ b/go/r3-eventbroker_zmq/main.go
@@ -10,6 +10,7 @@ import (
     "log/syslog"
     "log"
     pubsub "github.com/tuxychandru/pubsub"
+    "./r3events"
 )
 
 //~ func StringArrayToByteArray(ss []string) [][]byte {
@@ -78,7 +79,7 @@ func main() {
             //~ case <- ticker.C:
                 //~ MakeTimeTick(ps)
             case event_interface := <- publish_these_events_chan:
-                data, err := MarshalEvent(event_interface)
+                data, err := r3events.MarshalEvent2ByteByte(event_interface)
                 log.Printf("publishing %s",data)
                 if err != nil {
                     if Syslog_ != nil {Syslog_.Print(err)}