From 569939a7b37e15fd92a5549a44919f7c36308f06 Mon Sep 17 00:00:00 2001 From: hehaijunandhenry Date: Fri, 8 May 2026 17:21:25 +0800 Subject: [PATCH] Fix stop_mqtt_channel --- pkg/channels/mqtt/mqtt.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/channels/mqtt/mqtt.go b/pkg/channels/mqtt/mqtt.go index 39956ed9c..c34bc79bf 100644 --- a/pkg/channels/mqtt/mqtt.go +++ b/pkg/channels/mqtt/mqtt.go @@ -213,7 +213,7 @@ func (c *MQTTChannel) Stop(_ context.Context) error { logger.InfoC("mqtt", "Stopping MQTT channel") c.SetRunning(false) - if c.client != nil && c.client.IsConnected() { + if c.client != nil { c.client.Disconnect(500) }