Fix MQTT error and add error logging

ueckoken · Nov 21, 2023 · 0f6e1e4 · 0f6e1e4
1 parent e7a1db4
commit 0f6e1e4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/backend/state-manager/pkg/mqtt_handler/mqtt_handler.go b/backend/state-manager/pkg/mqtt_handler/mqtt_handler.go
@@ -24,6 +24,7 @@ func NewHandler(clientOpts *mqtt.ClientOptions, dbHandler *db.DBHandler) (*Handl
 
 	if token := cc.Connect(); token.Wait() && token.Error() != nil {
 		return nil, fmt.Errorf("mqtt error: %w", token.Error())
+		return nil, fmt.Errorf("mqtt error: %w", token.Error())
 	}
 	return &Handler{client: cc, dbHandler: dbHandler}, nil
 }