Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- diff -r cb269fd8f165 broadcast/alarmstream.go
- --- a/broadcast/alarmstream.go Mon Jan 14 15:09:00 2019 +0100
- +++ b/broadcast/alarmstream.go Wed Jan 16 17:06:39 2019 +0100
- @@ -181,6 +181,15 @@
- return nil
- }
- +func (asb *AlarmStreamBroker) heartbeat() {
- + // TODO: Implement me!
- +}
- +
- +func (asb *AlarmStreamBroker) HandleHeartbeat(json.RawMessage) error {
- + asb.cmds <- func() { asb.heartbeat() }
- + return nil
- +}
- +
- // HandleAlarm is the entry point for "Alarm" events.
- func (asb *AlarmStreamBroker) HandleAlarm(msg json.RawMessage) error {
- return asb.handle(msg, (*AlarmStreamBroker).handleAlarm)
- diff -r cb269fd8f165 broadcast/pointstream.go
- --- a/broadcast/pointstream.go Mon Jan 14 15:09:00 2019 +0100
- +++ b/broadcast/pointstream.go Wed Jan 16 17:06:39 2019 +0100
- @@ -210,6 +210,17 @@
- return nil
- }
- +func (psb *PointstreamBroker) heartbeat() {
- + // TODO: Implement me!
- +}
- +
- +// Handle the heartbeat from the Listen/Notify receiver.
- +func (psb *PointstreamBroker) HandleHeartbeat(json.RawMessage) error {
- + // Move to pointstream main.
- + psb.cmds <- func() { psb.heartbeat() }
- + return nil
- +}
- +
- func (psb *PointstreamBroker) registerClient(
- key string,
- geom wkt.Geom,
- diff -r cb269fd8f165 broadcast/receiver.go
- --- a/broadcast/receiver.go Mon Jan 14 15:09:00 2019 +0100
- +++ b/broadcast/receiver.go Wed Jan 16 17:06:39 2019 +0100
- @@ -84,6 +84,10 @@
- for {
- select {
- + case <-time.After(time.Minute):
- + rcv.dispatch(`{"type": "hb-light"}`)
- + rcv.dispatch(`{"type": "hb-alarm"}`)
- +
- case e := <-listener.Notify:
- if e == nil {
- continue
- diff -r cb269fd8f165 controllers/controller.go
- --- a/controllers/controller.go Mon Jan 14 15:09:00 2019 +0100
- +++ b/controllers/controller.go Wed Jan 16 17:06:39 2019 +0100
- @@ -12,11 +12,13 @@
- )
- const (
- - pointstreamType = "stroke"
- - alarmType = "Alarm"
- - allClearType = "Entwarnung"
- - testAlarmType = "Testalarm"
- - testAllClearType = "Testentwarnung"
- + pointstreamHeartbeatType = "hb-light"
- + alarmHeartbeatType = "hb-alarm"
- + pointstreamType = "stroke"
- + alarmType = "Alarm"
- + allClearType = "Entwarnung"
- + testAlarmType = "Testalarm"
- + testAllClearType = "Testentwarnung"
- )
- // Controller encapsulates the state known to all endpoints.
- @@ -44,7 +46,9 @@
- rcv := broadcast.NewReceiver(dsn)
- rcv.AddHandler(pointstreamType, c.psb.Handle)
- + rcv.AddHandler(pointstreamHeartbeatType, c.psb.HandleHeartbeat)
- rcv.AddHandler(alarmType, c.asb.HandleAlarm)
- + rcv.AddHandler(alarmHeartbeatType, c.asb.HandleHeartbeat)
- rcv.AddHandler(allClearType, c.asb.HandleAllClear)
- rcv.AddHandler(testAlarmType, c.asb.HandleTestAlarm)
- rcv.AddHandler(testAllClearType, c.asb.HandleTestAllClear)
Add Comment
Please, Sign In to add comment
