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 <[email protected]>
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;
}