This is an automated email from the ASF dual-hosted git repository. marat pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-karavan.git
The following commit(s) were added to refs/heads/main by this push: new e9136ff Convert implicit errorHandler to routeConfiguration e9136ff is described below commit e9136ffce6c73bf6a8c67b93ab030106a77c2524 Author: Marat Gubaidullin <marat.gubaidul...@gmail.com> AuthorDate: Wed Dec 21 18:08:37 2022 -0500 Convert implicit errorHandler to routeConfiguration --- karavan-core/src/core/api/CamelDefinitionYaml.ts | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/karavan-core/src/core/api/CamelDefinitionYaml.ts b/karavan-core/src/core/api/CamelDefinitionYaml.ts index 8aff38b..07f8a03 100644 --- a/karavan-core/src/core/api/CamelDefinitionYaml.ts +++ b/karavan-core/src/core/api/CamelDefinitionYaml.ts @@ -16,7 +16,7 @@ */ import * as yaml from 'js-yaml'; import {Integration, CamelElement, Beans} from "../model/IntegrationDefinition"; -import {RouteDefinition, NamedBeanDefinition} from "../model/CamelDefinition"; +import {RouteDefinition, NamedBeanDefinition, RouteConfigurationDefinition} from "../model/CamelDefinition"; import {CamelUtil} from "./CamelUtil"; import {CamelDefinitionYamlStep} from "./CamelDefinitionYamlStep"; @@ -188,6 +188,10 @@ export class CamelDefinitionYaml { .forEach((b: any) => result.push(CamelDefinitionYaml.readBeanDefinition(b))); flows.filter((e: any) => e.hasOwnProperty('routeConfiguration')) .forEach((e: any) => result.push(CamelDefinitionYamlStep.readRouteConfigurationDefinition(e.routeConfiguration))); + flows.filter((e: any) => e.hasOwnProperty('errorHandler')) + .forEach((f: any) => result.push(CamelDefinitionYamlStep.readRouteConfigurationDefinition(new RouteConfigurationDefinition({errorHandler: f.errorHandler})))); + flows.filter((e: any) => e.hasOwnProperty('onException')) + .forEach((f: any) => result.push(CamelDefinitionYamlStep.readRouteConfigurationDefinition(new RouteConfigurationDefinition({onException: f.onException})))); return result; }