sensorgauges
[svn42.git] / go / r3-eventbroker_zmq / main.go
index c80ea3a..492e7fb 100644 (file)
@@ -3,8 +3,6 @@
 package main
 
 import (
-    "fmt"
-    "os"
     "flag"
     //~ "time"
     pubsub "github.com/tuxychandru/pubsub"
@@ -32,11 +30,6 @@ var (
     enable_debuglog_ bool
 )
 
-func usage() {
-    fmt.Fprintf(os.Stderr, "Usage: zmq_broker_event_transformer [options]\n")
-    flag.PrintDefaults()
-}
-
 func init() {
     flag.StringVar(&door_cmd_addr_, "doorcmdaddr", "ipc:///run/tuer/door_cmd.ipc", "zmq door event publish addr")
     flag.StringVar(&doorsub_addr_, "doorsubaddr", "tcp://torwaechter.realraum.at:4242", "zmq door event publish addr")
@@ -46,7 +39,6 @@ func init() {
     flag.StringVar(&brain_listen_addr_, "brainlisten", "tcp://*:4245", "address to listen for requests about latest stored event")
     flag.BoolVar(&use_syslog_, "syslog", false, "log to syslog local2 facility")
     flag.BoolVar(&enable_debuglog_, "debug", false, "enable debug logging")
-    flag.Usage = usage
     flag.Parse()
 }
 
@@ -75,7 +67,7 @@ func main() {
     go BrainCenter(zmqctx, brain_listen_addr_, store_these_events_chan)
 
     go MetaEventRoutine_Movement(ps, 10, 20, 10)
-    go MetaEventRoutine_Presence(ps)
+    go MetaEventRoutine_Presence(ps, 21, 200)
 
     // --- get update on most recent status ---
     answ := ZmqsAskQuestionsAndClose(zmqctx, door_cmd_addr_, [][][]byte{[][]byte{[]byte("status")}})