diff --git a/backend/state-manager/pkg/mqtt_handler/mqtt_handler.go b/backend/state-manager/pkg/mqtt_handler/mqtt_handler.go index 92cf4c4..bccd6bf 100644 --- 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 }