diff options
Diffstat (limited to '')
| -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() |