MQTT: re-set "retain" to false as default

Support for "retain" is currently broken

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
This commit is contained in:
ItalyPaleAle 2022-06-23 00:46:53 +00:00
parent 8974eca74c
commit be2fed6b3a
2 changed files with 2 additions and 2 deletions

View File

@ -46,7 +46,7 @@ const (
// Defaults.
defaultQOS = 1
defaultRetain = true
defaultRetain = false
defaultWait = 30 * time.Second
defaultCleanSession = false
)

View File

@ -106,7 +106,7 @@ func TestParseMetadata(t *testing.T) {
assert.NoError(t, err)
assert.Equal(t, fakeProperties[mqttURL], m.url)
assert.Equal(t, byte(1), m.qos)
assert.Equal(t, true, m.retain)
assert.Equal(t, false, m.retain)
})
t.Run("invalid clean session field", func(t *testing.T) {