X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fr3-eventbroker_zmq%2Fmain.go;h=6d1a5cdc379d2090ddc2097058f5c5e8cff755f1;hb=957f71721b04698dd588ffc8dc2ed10775050451;hp=dbd35eb346503a17713a40d7de5fa4e5291ca46a;hpb=41e56d488bc8f08dbd4d15b66bcbfa7c47fe0417;p=svn42.git

diff --git a/go/r3-eventbroker_zmq/main.go b/go/r3-eventbroker_zmq/main.go
index dbd35eb..6d1a5cd 100644
--- a/go/r3-eventbroker_zmq/main.go
+++ b/go/r3-eventbroker_zmq/main.go
@@ -53,6 +53,10 @@ func main() {
     defer pub_out_socket.Close()
     defer keylookup_socket.Close()
     
+    if sub_in_chans == nil || pub_out_socket == nil || keylookup_socket == nil {
+        panic("zmq sockets must not be nil !!")
+    }
+    
     if use_syslog_ {
         var logerr error
         Syslog_, logerr = syslog.NewLogger(syslog.LOG_INFO | (18<<3), 0)
@@ -69,6 +73,12 @@ func main() {
     go MetaEventRoutine_Movement(ps, 10, 20, 10)
     go MetaEventRoutine_Presence(ps)
     
+    for xx := range(sub_in_chans.In()) {
+        log.Print(xx)
+        Syslog_.Print(xx)
+    }
+    
+    
     for {
         log.Print("for loop")
         select {