diff options
| author | Ethel Morgan <eth@ethulhu.co.uk> | 2020-06-22 21:39:03 +0100 |
|---|---|---|
| committer | Ethel Morgan <eth@ethulhu.co.uk> | 2020-06-22 21:39:03 +0100 |
| commit | d5b2961bd2cc474d763d72ad1c180e7358e5fd6d (patch) | |
| tree | c9ca0e59e46362d93d2aa045894008554f633e8c | |
| parent | b80f8b26b1a7d3d1974c77e92515ba8a650bfe45 (diff) | |
default rebroadcast values are set to Retain
| -rw-r--r-- | catbus/catbus.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/catbus/catbus.go b/catbus/catbus.go index a76e644..2538a2f 100644 --- a/catbus/catbus.go +++ b/catbus/catbus.go @@ -75,7 +75,7 @@ func NewClient(brokerURI string, options ClientOptions) *Client { } for topic, payload := range options.RebroadcastDefaults { // TODO: Allow users to set retention? - client.rebroadcastLater(topic, DontRetain, payload) + client.rebroadcastLater(topic, Retain, payload) } mqttOpts := mqtt.NewClientOptions() |