fix lock releasing in mqtt client on error

2026-08-17 12:23:22 +00:00 · 2026-08-11 19:58:33 -05:00
parent a1f7bca743
commit 7c0a504616
1 changed files with 1 additions and 1 deletions
@@ -148,13 +148,13 @@ func (mc *MQTTClient) Start(ctx context.Context, inputHandler common.InputHandle
 	mc.client = mqtt.NewClient(opts)

 	token := mc.client.Connect()
+	mc.clientMu.Unlock()

 	token.Wait()
 	err := token.Error()
 	if err != nil {
 		return err
 	}
-	mc.clientMu.Unlock()

 	<-mc.ctx.Done()
 	mc.logger.Debug("done")