opencode/picoclaw
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix stop_mqtt_channel

Browse source
This commit is contained in:
hehaijunandhenry 2026-05-08 17:21:25 +08:00
parent 2287de521e
commit 569939a7b3
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
pkg/channels/mqtt/mqtt.go
View file

@ -213,7 +213,7 @@ func (c *MQTTChannel) Stop(_ context.Context) error {
logger.InfoC("mqtt", "Stopping MQTT channel") logger.InfoC("mqtt", "Stopping MQTT channel")
c.SetRunning(false) c.SetRunning(false)
if c.client != nil && c.client.IsConnected() { if c.client != nil {
c.client.Disconnect(500) c.client.Disconnect(500)
} }