From d5b2961bd2cc474d763d72ad1c180e7358e5fd6d Mon Sep 17 00:00:00 2001 From: Ethel Morgan Date: Mon, 22 Jun 2020 21:39:03 +0100 Subject: default rebroadcast values are set to Retain --- catbus/catbus.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'catbus/catbus.go') 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() -- cgit v1.2.3