diff --git a/internal/module/mqtt-client.go b/internal/module/mqtt-client.go
index 081185b..728b075 100644
--- a/internal/module/mqtt-client.go
+++ b/internal/module/mqtt-client.go
@@ -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")