From c749c43dabbbe2c2545999c199bc7bfb03eb0b21 Mon Sep 17 00:00:00 2001 From: Daniel Nelson Date: Mon, 2 Oct 2017 12:28:31 -0700 Subject: [PATCH] Fix mqtt_consumer connection_timeout test (cherry picked from commit cdca81c9999364cf6fb35f25fabdad31bb81a177) --- plugins/inputs/mqtt_consumer/mqtt_consumer.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/plugins/inputs/mqtt_consumer/mqtt_consumer.go b/plugins/inputs/mqtt_consumer/mqtt_consumer.go index e0d668879..ddffbf258 100644 --- a/plugins/inputs/mqtt_consumer/mqtt_consumer.go +++ b/plugins/inputs/mqtt_consumer/mqtt_consumer.go @@ -121,8 +121,8 @@ func (m *MQTTConsumer) Start(acc telegraf.Accumulator) error { return fmt.Errorf("MQTT Consumer, invalid QoS value: %d", m.QoS) } - if int(m.ConnectionTimeout.Duration) <= 0 { - return fmt.Errorf("MQTT Consumer, invalid connection_timeout value: %d", m.ConnectionTimeout) + if m.ConnectionTimeout.Duration < 1*time.Second { + return fmt.Errorf("MQTT Consumer, invalid connection_timeout value: %s", m.ConnectionTimeout.Duration) } opts, err := m.createOpts()