diff options
| author | Ethel Morgan <eth@ethulhu.co.uk> | 2020-06-22 21:25:47 +0100 |
|---|---|---|
| committer | Ethel Morgan <eth@ethulhu.co.uk> | 2020-06-22 21:25:47 +0100 |
| commit | b9f13df51979ff38e4a9578f982cc608e3bb2c0d (patch) | |
| tree | c6763a4c8ab57b2670d635545d7d10225efe8314 /cmd/catbus-actuator-wakeonlan/main.go | |
| parent | 09bb9e12fcd0336af2a3a9f9aacc6384ac004943 (diff) | |
add rebroadcasting to package catbus
Diffstat (limited to 'cmd/catbus-actuator-wakeonlan/main.go')
| -rw-r--r-- | cmd/catbus-actuator-wakeonlan/main.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/cmd/catbus-actuator-wakeonlan/main.go b/cmd/catbus-actuator-wakeonlan/main.go index 37efbbe..6f4e62b 100644 --- a/cmd/catbus-actuator-wakeonlan/main.go +++ b/cmd/catbus-actuator-wakeonlan/main.go @@ -73,6 +73,12 @@ func main() { } }, } + + catbusOptions.RebroadcastDefaults = map[string][]byte{} + for topic := range config.MACsByTopic { + catbusOptions.RebroadcastDefaults[topic] = []byte("off") + } + catbus := catbus.NewClient(config.BrokerURI, catbusOptions) if err := catbus.Connect(); err != nil { |