| /** |
| * Generated by karavan build tools - do NOT edit this file! |
| */ |
| import {CamelElement} from "../model/IntegrationDefinition"; |
| import { |
| |
| ProcessorDefinition, |
| BeansDeserializer, |
| ErrorHandlerBuilderDeserializer, |
| NamedBeanDefinition, |
| OutputAwareFromDefinition, |
| AggregateDefinition, |
| BeanDefinition, |
| CatchDefinition, |
| ChoiceDefinition, |
| CircuitBreakerDefinition, |
| ClaimCheckDefinition, |
| ContextScanDefinition, |
| ConvertBodyDefinition, |
| DataFormatDefinition, |
| DelayDefinition, |
| DescriptionDefinition, |
| DynamicRouterDefinition, |
| EnrichDefinition, |
| ErrorHandlerDefinition, |
| ExpressionSubElementDefinition, |
| FaultToleranceConfigurationDefinition, |
| FilterDefinition, |
| FinallyDefinition, |
| FromDefinition, |
| GlobalOptionDefinition, |
| GlobalOptionsDefinition, |
| IdempotentConsumerDefinition, |
| InOnlyDefinition, |
| InOutDefinition, |
| InputTypeDefinition, |
| InterceptDefinition, |
| InterceptFromDefinition, |
| InterceptSendToEndpointDefinition, |
| KameletDefinition, |
| LoadBalanceDefinition, |
| LogDefinition, |
| LoopDefinition, |
| MarshalDefinition, |
| MulticastDefinition, |
| OnCompletionDefinition, |
| OnExceptionDefinition, |
| OnFallbackDefinition, |
| OptimisticLockRetryPolicyDefinition, |
| OtherwiseDefinition, |
| OutputDefinition, |
| OutputTypeDefinition, |
| PackageScanDefinition, |
| PausableDefinition, |
| PipelineDefinition, |
| PolicyDefinition, |
| PollEnrichDefinition, |
| ProcessDefinition, |
| PropertyDefinition, |
| PropertyExpressionDefinition, |
| RecipientListDefinition, |
| RedeliveryPolicyDefinition, |
| RemoveHeaderDefinition, |
| RemoveHeadersDefinition, |
| RemovePropertiesDefinition, |
| RemovePropertyDefinition, |
| ResequenceDefinition, |
| Resilience4jConfigurationDefinition, |
| RestContextRefDefinition, |
| ResumableDefinition, |
| RollbackDefinition, |
| RouteBuilderDefinition, |
| RouteConfigurationContextRefDefinition, |
| RouteConfigurationDefinition, |
| RouteContextRefDefinition, |
| RouteDefinition, |
| RouteTemplateBeanDefinition, |
| RouteTemplateDefinition, |
| RouteTemplateParameterDefinition, |
| RoutingSlipDefinition, |
| SagaActionUriDefinition, |
| SagaDefinition, |
| SamplingDefinition, |
| ScriptDefinition, |
| SetBodyDefinition, |
| SetExchangePatternDefinition, |
| SetHeaderDefinition, |
| SetPropertyDefinition, |
| SortDefinition, |
| SplitDefinition, |
| StepDefinition, |
| StopDefinition, |
| TemplatedRouteBeanDefinition, |
| TemplatedRouteDefinition, |
| TemplatedRouteParameterDefinition, |
| ThreadPoolProfileDefinition, |
| ThreadsDefinition, |
| ThrottleDefinition, |
| ThrowExceptionDefinition, |
| ToDefinition, |
| ToDynamicDefinition, |
| TransactedDefinition, |
| TransformDefinition, |
| TryDefinition, |
| UnmarshalDefinition, |
| ValidateDefinition, |
| WhenDefinition, |
| WhenSkipSendToEndpointDefinition, |
| WireTapDefinition, |
| BlacklistServiceCallServiceFilterConfiguration, |
| CachingServiceCallServiceDiscoveryConfiguration, |
| CombinedServiceCallServiceDiscoveryConfiguration, |
| CombinedServiceCallServiceFilterConfiguration, |
| ConsulServiceCallServiceDiscoveryConfiguration, |
| CustomServiceCallServiceFilterConfiguration, |
| DefaultServiceCallServiceLoadBalancerConfiguration, |
| DnsServiceCallServiceDiscoveryConfiguration, |
| HealthyServiceCallServiceFilterConfiguration, |
| KubernetesServiceCallServiceDiscoveryConfiguration, |
| PassThroughServiceCallServiceFilterConfiguration, |
| ServiceCallConfigurationDefinition, |
| ServiceCallDefinition, |
| ServiceCallExpressionConfiguration, |
| ServiceCallServiceChooserConfiguration, |
| ServiceCallServiceDiscoveryConfiguration, |
| ServiceCallServiceFilterConfiguration, |
| ServiceCallServiceLoadBalancerConfiguration, |
| StaticServiceCallServiceDiscoveryConfiguration, |
| ZooKeeperServiceCallServiceDiscoveryConfiguration, |
| BatchResequencerConfig, |
| StreamResequencerConfig, |
| ASN1DataFormat, |
| Any23DataFormat, |
| AvroDataFormat, |
| BarcodeDataFormat, |
| Base64DataFormat, |
| BindyDataFormat, |
| CBORDataFormat, |
| CryptoDataFormat, |
| CsvDataFormat, |
| CustomDataFormat, |
| DataFormatsDefinition, |
| FhirJsonDataFormat, |
| FhirXmlDataFormat, |
| FlatpackDataFormat, |
| GrokDataFormat, |
| GzipDeflaterDataFormat, |
| HL7DataFormat, |
| IcalDataFormat, |
| JacksonXMLDataFormat, |
| JaxbDataFormat, |
| JsonApiDataFormat, |
| JsonDataFormat, |
| LZFDataFormat, |
| MimeMultipartDataFormat, |
| PGPDataFormat, |
| ProtobufDataFormat, |
| RssDataFormat, |
| SoapDataFormat, |
| SyslogDataFormat, |
| TarFileDataFormat, |
| ThriftDataFormat, |
| TidyMarkupDataFormat, |
| UniVocityCsvDataFormat, |
| UniVocityFixedDataFormat, |
| UniVocityHeader, |
| UniVocityTsvDataFormat, |
| XMLSecurityDataFormat, |
| XStreamDataFormat, |
| YAMLDataFormat, |
| YAMLTypeFilterDefinition, |
| ZipDeflaterDataFormat, |
| ZipFileDataFormat, |
| DeadLetterChannelDefinition, |
| DefaultErrorHandlerDefinition, |
| ErrorHandlerRefDefinition, |
| JtaTransactionErrorHandlerDefinition, |
| NoErrorHandlerDefinition, |
| SpringTransactionErrorHandlerDefinition, |
| CSimpleExpression, |
| ConstantExpression, |
| DatasonnetExpression, |
| ExchangePropertyExpression, |
| ExpressionDefinition, |
| GroovyExpression, |
| HeaderExpression, |
| Hl7TerserExpression, |
| JoorExpression, |
| JqExpression, |
| JsonPathExpression, |
| LanguageExpression, |
| MethodCallExpression, |
| MvelExpression, |
| OgnlExpression, |
| RefExpression, |
| SimpleExpression, |
| SpELExpression, |
| TokenizerExpression, |
| XMLTokenizerExpression, |
| XPathExpression, |
| XQueryExpression, |
| CustomLoadBalancerDefinition, |
| FailoverLoadBalancerDefinition, |
| RandomLoadBalancerDefinition, |
| RoundRobinLoadBalancerDefinition, |
| StickyLoadBalancerDefinition, |
| TopicLoadBalancerDefinition, |
| WeightedLoadBalancerDefinition, |
| ApiKeyDefinition, |
| BasicAuthDefinition, |
| BearerTokenDefinition, |
| DeleteDefinition, |
| GetDefinition, |
| HeadDefinition, |
| MutualTLSDefinition, |
| OAuth2Definition, |
| OpenIdConnectDefinition, |
| ParamDefinition, |
| PatchDefinition, |
| PostDefinition, |
| PutDefinition, |
| ResponseHeaderDefinition, |
| ResponseMessageDefinition, |
| RestBindingDefinition, |
| RestConfigurationDefinition, |
| RestDefinition, |
| RestPropertyDefinition, |
| RestSecuritiesDefinition, |
| RestsDefinition, |
| SecurityDefinition, |
| CustomTransformerDefinition, |
| DataFormatTransformerDefinition, |
| EndpointTransformerDefinition, |
| TransformersDefinition, |
| CustomValidatorDefinition, |
| EndpointValidatorDefinition, |
| PredicateValidatorDefinition, |
| ValidatorsDefinition, |
| } from '../model/CamelDefinition'; |
| import {CamelUtil} from './CamelUtil'; |
| import {CamelMetadataApi} from '../model/CamelMetadata'; |
| |
| export class CamelDefinitionYamlStep { |
| |
| static readProcessorDefinition = (element: any): ProcessorDefinition => { |
| |
| const def = element ? new ProcessorDefinition({...element}) : new ProcessorDefinition(); |
| if (element?.idempotentConsumer !== undefined) { |
| def.idempotentConsumer = CamelDefinitionYamlStep.readIdempotentConsumerDefinition(element.idempotentConsumer); |
| } |
| if (element?.resumable !== undefined) { |
| def.resumable = CamelDefinitionYamlStep.readResumableDefinition(element.resumable); |
| } |
| if (element?.doTry !== undefined) { |
| def.doTry = CamelDefinitionYamlStep.readTryDefinition(element.doTry); |
| } |
| if (element?.convertBodyTo !== undefined) { |
| def.convertBodyTo = CamelDefinitionYamlStep.readConvertBodyDefinition(element.convertBodyTo); |
| } |
| if (element?.recipientList !== undefined) { |
| def.recipientList = CamelDefinitionYamlStep.readRecipientListDefinition(element.recipientList); |
| } |
| if (element?.when !== undefined) { |
| def.when = CamelDefinitionYamlStep.readWhenDefinition(element.when); |
| } |
| if (element?.setHeader !== undefined) { |
| def.setHeader = CamelDefinitionYamlStep.readSetHeaderDefinition(element.setHeader); |
| } |
| if (element?.inOnly !== undefined) { |
| def.inOnly = CamelDefinitionYamlStep.readInOnlyDefinition(element.inOnly); |
| } |
| if (element?.inOut !== undefined) { |
| def.inOut = CamelDefinitionYamlStep.readInOutDefinition(element.inOut); |
| } |
| if (element?.split !== undefined) { |
| def.split = CamelDefinitionYamlStep.readSplitDefinition(element.split); |
| } |
| if (element?.interceptSendToEndpoint !== undefined) { |
| def.interceptSendToEndpoint = CamelDefinitionYamlStep.readInterceptSendToEndpointDefinition(element.interceptSendToEndpoint); |
| } |
| if (element?.loop !== undefined) { |
| def.loop = CamelDefinitionYamlStep.readLoopDefinition(element.loop); |
| } |
| if (element?.setExchangePattern !== undefined) { |
| def.setExchangePattern = CamelDefinitionYamlStep.readSetExchangePatternDefinition(element.setExchangePattern); |
| } |
| if (element?.marshal !== undefined) { |
| def.marshal = CamelDefinitionYamlStep.readMarshalDefinition(element.marshal); |
| } |
| if (element?.onFallback !== undefined) { |
| def.onFallback = CamelDefinitionYamlStep.readOnFallbackDefinition(element.onFallback); |
| } |
| if (element?.circuitBreaker !== undefined) { |
| def.circuitBreaker = CamelDefinitionYamlStep.readCircuitBreakerDefinition(element.circuitBreaker); |
| } |
| if (element?.enrich !== undefined) { |
| def.enrich = CamelDefinitionYamlStep.readEnrichDefinition(element.enrich); |
| } |
| if (element?.kamelet !== undefined) { |
| def.kamelet = CamelDefinitionYamlStep.readKameletDefinition(element.kamelet); |
| } |
| if (element?.saga !== undefined) { |
| def.saga = CamelDefinitionYamlStep.readSagaDefinition(element.saga); |
| } |
| if (element?.bean !== undefined) { |
| def.bean = CamelDefinitionYamlStep.readBeanDefinition(element.bean); |
| } |
| if (element?.otherwise !== undefined) { |
| def.otherwise = CamelDefinitionYamlStep.readOtherwiseDefinition(element.otherwise); |
| } |
| if (element?.sort !== undefined) { |
| def.sort = CamelDefinitionYamlStep.readSortDefinition(element.sort); |
| } |
| if (element?.loadBalance !== undefined) { |
| def.loadBalance = CamelDefinitionYamlStep.readLoadBalanceDefinition(element.loadBalance); |
| } |
| if (element?.script !== undefined) { |
| def.script = CamelDefinitionYamlStep.readScriptDefinition(element.script); |
| } |
| if (element?.removeHeader !== undefined) { |
| def.removeHeader = CamelDefinitionYamlStep.readRemoveHeaderDefinition(element.removeHeader); |
| } |
| if (element?.delay !== undefined) { |
| def.delay = CamelDefinitionYamlStep.readDelayDefinition(element.delay); |
| } |
| if (element?.stop !== undefined) { |
| def.stop = CamelDefinitionYamlStep.readStopDefinition(element.stop); |
| } |
| if (element?.serviceCall !== undefined) { |
| def.serviceCall = CamelDefinitionYamlStep.readServiceCallDefinition(element.serviceCall); |
| } |
| if (element?.intercept !== undefined) { |
| def.intercept = CamelDefinitionYamlStep.readInterceptDefinition(element.intercept); |
| } |
| if (element?.whenSkipSendToEndpoint !== undefined) { |
| def.whenSkipSendToEndpoint = CamelDefinitionYamlStep.readWhenSkipSendToEndpointDefinition(element.whenSkipSendToEndpoint); |
| } |
| if (element?.setProperty !== undefined) { |
| def.setProperty = CamelDefinitionYamlStep.readSetPropertyDefinition(element.setProperty); |
| } |
| if (element?.removeProperty !== undefined) { |
| def.removeProperty = CamelDefinitionYamlStep.readRemovePropertyDefinition(element.removeProperty); |
| } |
| if (element?.interceptFrom !== undefined) { |
| def.interceptFrom = CamelDefinitionYamlStep.readInterceptFromDefinition(element.interceptFrom); |
| } |
| if (element?.onCompletion !== undefined) { |
| def.onCompletion = CamelDefinitionYamlStep.readOnCompletionDefinition(element.onCompletion); |
| } |
| if (element?.pausable !== undefined) { |
| def.pausable = CamelDefinitionYamlStep.readPausableDefinition(element.pausable); |
| } |
| if (element?.throttle !== undefined) { |
| def.throttle = CamelDefinitionYamlStep.readThrottleDefinition(element.throttle); |
| } |
| if (element?.doFinally !== undefined) { |
| def.doFinally = CamelDefinitionYamlStep.readFinallyDefinition(element.doFinally); |
| } |
| if (element?.log !== undefined) { |
| def.log = CamelDefinitionYamlStep.readLogDefinition(element.log); |
| } |
| if (element?.doCatch !== undefined) { |
| def.doCatch = CamelDefinitionYamlStep.readCatchDefinition(element.doCatch); |
| } |
| if (element?.transacted !== undefined) { |
| def.transacted = CamelDefinitionYamlStep.readTransactedDefinition(element.transacted); |
| } |
| if (element?.claimCheck !== undefined) { |
| def.claimCheck = CamelDefinitionYamlStep.readClaimCheckDefinition(element.claimCheck); |
| } |
| if (element?.pollEnrich !== undefined) { |
| def.pollEnrich = CamelDefinitionYamlStep.readPollEnrichDefinition(element.pollEnrich); |
| } |
| if (element?.removeHeaders !== undefined) { |
| def.removeHeaders = CamelDefinitionYamlStep.readRemoveHeadersDefinition(element.removeHeaders); |
| } |
| if (element?.aggregate !== undefined) { |
| def.aggregate = CamelDefinitionYamlStep.readAggregateDefinition(element.aggregate); |
| } |
| if (element?.resequence !== undefined) { |
| def.resequence = CamelDefinitionYamlStep.readResequenceDefinition(element.resequence); |
| } |
| if (element?.routingSlip !== undefined) { |
| def.routingSlip = CamelDefinitionYamlStep.readRoutingSlipDefinition(element.routingSlip); |
| } |
| if (element?.transform !== undefined) { |
| def.transform = CamelDefinitionYamlStep.readTransformDefinition(element.transform); |
| } |
| if (element?.removeProperties !== undefined) { |
| def.removeProperties = CamelDefinitionYamlStep.readRemovePropertiesDefinition(element.removeProperties); |
| } |
| if (element?.policy !== undefined) { |
| def.policy = CamelDefinitionYamlStep.readPolicyDefinition(element.policy); |
| } |
| if (element?.validate !== undefined) { |
| def.validate = CamelDefinitionYamlStep.readValidateDefinition(element.validate); |
| } |
| if (element?.rollback !== undefined) { |
| def.rollback = CamelDefinitionYamlStep.readRollbackDefinition(element.rollback); |
| } |
| if (element?.process !== undefined) { |
| def.process = CamelDefinitionYamlStep.readProcessDefinition(element.process); |
| } |
| if (element?.threads !== undefined) { |
| def.threads = CamelDefinitionYamlStep.readThreadsDefinition(element.threads); |
| } |
| if (element?.setBody !== undefined) { |
| def.setBody = CamelDefinitionYamlStep.readSetBodyDefinition(element.setBody); |
| } |
| if (element?.sample !== undefined) { |
| def.sample = CamelDefinitionYamlStep.readSamplingDefinition(element.sample); |
| } |
| if (element?.throwException !== undefined) { |
| def.throwException = CamelDefinitionYamlStep.readThrowExceptionDefinition(element.throwException); |
| } |
| if (element?.dynamicRouter !== undefined) { |
| def.dynamicRouter = CamelDefinitionYamlStep.readDynamicRouterDefinition(element.dynamicRouter); |
| } |
| if (element?.multicast !== undefined) { |
| def.multicast = CamelDefinitionYamlStep.readMulticastDefinition(element.multicast); |
| } |
| if (element?.filter !== undefined) { |
| def.filter = CamelDefinitionYamlStep.readFilterDefinition(element.filter); |
| } |
| if (element?.pipeline !== undefined) { |
| def.pipeline = CamelDefinitionYamlStep.readPipelineDefinition(element.pipeline); |
| } |
| if (element?.unmarshal !== undefined) { |
| def.unmarshal = CamelDefinitionYamlStep.readUnmarshalDefinition(element.unmarshal); |
| } |
| if (element?.wireTap !== undefined) { |
| def.wireTap = CamelDefinitionYamlStep.readWireTapDefinition(element.wireTap); |
| } |
| if (element?.step !== undefined) { |
| def.step = CamelDefinitionYamlStep.readStepDefinition(element.step); |
| } |
| if (element?.choice !== undefined) { |
| def.choice = CamelDefinitionYamlStep.readChoiceDefinition(element.choice); |
| } |
| |
| return def; |
| } |
| |
| static readBeansDeserializer = (element: any): BeansDeserializer => { |
| |
| const def = element ? new BeansDeserializer({...element}) : new BeansDeserializer(); |
| |
| return def; |
| } |
| |
| static readErrorHandlerBuilderDeserializer = (element: any): ErrorHandlerBuilderDeserializer => { |
| |
| const def = element ? new ErrorHandlerBuilderDeserializer({...element}) : new ErrorHandlerBuilderDeserializer(); |
| if (element?.deadLetterChannel !== undefined) { |
| def.deadLetterChannel = CamelDefinitionYamlStep.readDeadLetterChannelDefinition(element.deadLetterChannel); |
| } |
| if (element?.log !== undefined) { |
| def.log = CamelDefinitionYamlStep.readDefaultErrorHandlerDefinition(element.log); |
| } |
| if (element?.none !== undefined) { |
| def.none = CamelDefinitionYamlStep.readNoErrorHandlerDefinition(element.none); |
| } |
| |
| return def; |
| } |
| |
| static readNamedBeanDefinition = (element: any): NamedBeanDefinition => { |
| |
| const def = element ? new NamedBeanDefinition({...element}) : new NamedBeanDefinition(); |
| |
| return def; |
| } |
| |
| static readOutputAwareFromDefinition = (element: any): OutputAwareFromDefinition => { |
| |
| const def = element ? new OutputAwareFromDefinition({...element}) : new OutputAwareFromDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readAggregateDefinition = (element: any): AggregateDefinition => { |
| |
| const def = element ? new AggregateDefinition({...element}) : new AggregateDefinition(); |
| if (element?.completionTimeoutExpression !== undefined) { |
| def.completionTimeoutExpression = CamelDefinitionYamlStep.readExpressionSubElementDefinition(element.completionTimeoutExpression); |
| } |
| if (element?.correlationExpression !== undefined) { |
| def.correlationExpression = CamelDefinitionYamlStep.readExpressionSubElementDefinition(element.correlationExpression); |
| } |
| if (element?.completionPredicate !== undefined) { |
| def.completionPredicate = CamelDefinitionYamlStep.readExpressionSubElementDefinition(element.completionPredicate); |
| } |
| if (element?.optimisticLockRetryPolicy !== undefined) { |
| def.optimisticLockRetryPolicy = CamelDefinitionYamlStep.readOptimisticLockRetryPolicyDefinition(element.optimisticLockRetryPolicy); |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| if (element?.completionSizeExpression !== undefined) { |
| def.completionSizeExpression = CamelDefinitionYamlStep.readExpressionSubElementDefinition(element.completionSizeExpression); |
| } |
| |
| return def; |
| } |
| |
| static readBeanDefinition = (element: any): BeanDefinition => { |
| |
| const def = element ? new BeanDefinition({...element}) : new BeanDefinition(); |
| |
| return def; |
| } |
| |
| static readCatchDefinition = (element: any): CatchDefinition => { |
| |
| const def = element ? new CatchDefinition({...element}) : new CatchDefinition(); |
| if (element?.onWhen !== undefined) { |
| def.onWhen = CamelDefinitionYamlStep.readWhenDefinition(element.onWhen); |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readChoiceDefinition = (element: any): ChoiceDefinition => { |
| |
| const def = element ? new ChoiceDefinition({...element}) : new ChoiceDefinition(); |
| if (element?.otherwise !== undefined) { |
| def.otherwise = CamelDefinitionYamlStep.readOtherwiseDefinition(element.otherwise); |
| } |
| def.when = element && element?.when ? element?.when.map((x:any) => CamelDefinitionYamlStep.readWhenDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readCircuitBreakerDefinition = (element: any): CircuitBreakerDefinition => { |
| |
| const def = element ? new CircuitBreakerDefinition({...element}) : new CircuitBreakerDefinition(); |
| if (element?.faultToleranceConfiguration !== undefined) { |
| def.faultToleranceConfiguration = CamelDefinitionYamlStep.readFaultToleranceConfigurationDefinition(element.faultToleranceConfiguration); |
| } |
| if (element?.resilience4jConfiguration !== undefined) { |
| def.resilience4jConfiguration = CamelDefinitionYamlStep.readResilience4jConfigurationDefinition(element.resilience4jConfiguration); |
| } |
| if (element?.onFallback !== undefined) { |
| def.onFallback = CamelDefinitionYamlStep.readOnFallbackDefinition(element.onFallback); |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readClaimCheckDefinition = (element: any): ClaimCheckDefinition => { |
| |
| const def = element ? new ClaimCheckDefinition({...element}) : new ClaimCheckDefinition(); |
| |
| return def; |
| } |
| |
| static readContextScanDefinition = (element: any): ContextScanDefinition => { |
| |
| const def = element ? new ContextScanDefinition({...element}) : new ContextScanDefinition(); |
| |
| return def; |
| } |
| |
| static readConvertBodyDefinition = (element: any): ConvertBodyDefinition => { |
| if (element && typeof element === 'string') element = {type: element}; |
| const def = element ? new ConvertBodyDefinition({...element}) : new ConvertBodyDefinition(); |
| |
| return def; |
| } |
| |
| static readDataFormatDefinition = (element: any): DataFormatDefinition => { |
| |
| const def = element ? new DataFormatDefinition({...element}) : new DataFormatDefinition(); |
| |
| return def; |
| } |
| |
| static readDelayDefinition = (element: any): DelayDefinition => { |
| |
| const def = element ? new DelayDefinition({...element}) : new DelayDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readDescriptionDefinition = (element: any): DescriptionDefinition => { |
| |
| const def = element ? new DescriptionDefinition({...element}) : new DescriptionDefinition(); |
| |
| return def; |
| } |
| |
| static readDynamicRouterDefinition = (element: any): DynamicRouterDefinition => { |
| |
| const def = element ? new DynamicRouterDefinition({...element}) : new DynamicRouterDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readEnrichDefinition = (element: any): EnrichDefinition => { |
| |
| const def = element ? new EnrichDefinition({...element}) : new EnrichDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readErrorHandlerDefinition = (element: any): ErrorHandlerDefinition => { |
| |
| const def = element ? new ErrorHandlerDefinition({...element}) : new ErrorHandlerDefinition(); |
| if (element?.deadLetterChannel !== undefined) { |
| def.deadLetterChannel = CamelDefinitionYamlStep.readDeadLetterChannelDefinition(element.deadLetterChannel); |
| } |
| if (element?.noErrorHandler !== undefined) { |
| def.noErrorHandler = CamelDefinitionYamlStep.readNoErrorHandlerDefinition(element.noErrorHandler); |
| } |
| if (element?.jtaTransactionErrorHandler !== undefined) { |
| def.jtaTransactionErrorHandler = CamelDefinitionYamlStep.readJtaTransactionErrorHandlerDefinition(element.jtaTransactionErrorHandler); |
| } |
| if (element?.defaultErrorHandler !== undefined) { |
| def.defaultErrorHandler = CamelDefinitionYamlStep.readDefaultErrorHandlerDefinition(element.defaultErrorHandler); |
| } |
| if (element?.springTransactionErrorHandler !== undefined) { |
| def.springTransactionErrorHandler = CamelDefinitionYamlStep.readSpringTransactionErrorHandlerDefinition(element.springTransactionErrorHandler); |
| } |
| |
| return def; |
| } |
| |
| static readExpressionSubElementDefinition = (element: any): ExpressionSubElementDefinition => { |
| |
| const def = element ? new ExpressionSubElementDefinition({...element}) : new ExpressionSubElementDefinition(); |
| if (element?.ognl !== undefined) { |
| def.ognl = CamelDefinitionYamlStep.readOgnlExpression(element.ognl); |
| } |
| if (element?.constant !== undefined) { |
| def.constant = CamelDefinitionYamlStep.readConstantExpression(element.constant); |
| } |
| if (element?.mvel !== undefined) { |
| def.mvel = CamelDefinitionYamlStep.readMvelExpression(element.mvel); |
| } |
| if (element?.method !== undefined) { |
| def.method = CamelDefinitionYamlStep.readMethodCallExpression(element.method); |
| } |
| if (element?.xquery !== undefined) { |
| def.xquery = CamelDefinitionYamlStep.readXQueryExpression(element.xquery); |
| } |
| if (element?.datasonnet !== undefined) { |
| def.datasonnet = CamelDefinitionYamlStep.readDatasonnetExpression(element.datasonnet); |
| } |
| if (element?.jq !== undefined) { |
| def.jq = CamelDefinitionYamlStep.readJqExpression(element.jq); |
| } |
| if (element?.language !== undefined) { |
| def.language = CamelDefinitionYamlStep.readLanguageExpression(element.language); |
| } |
| if (element?.simple !== undefined) { |
| def.simple = CamelDefinitionYamlStep.readSimpleExpression(element.simple); |
| } |
| if (element?.hl7terser !== undefined) { |
| def.hl7terser = CamelDefinitionYamlStep.readHl7TerserExpression(element.hl7terser); |
| } |
| if (element?.tokenize !== undefined) { |
| def.tokenize = CamelDefinitionYamlStep.readTokenizerExpression(element.tokenize); |
| } |
| if (element?.spel !== undefined) { |
| def.spel = CamelDefinitionYamlStep.readSpELExpression(element.spel); |
| } |
| if (element?.ref !== undefined) { |
| def.ref = CamelDefinitionYamlStep.readRefExpression(element.ref); |
| } |
| if (element?.xpath !== undefined) { |
| def.xpath = CamelDefinitionYamlStep.readXPathExpression(element.xpath); |
| } |
| if (element?.groovy !== undefined) { |
| def.groovy = CamelDefinitionYamlStep.readGroovyExpression(element.groovy); |
| } |
| if (element?.csimple !== undefined) { |
| def.csimple = CamelDefinitionYamlStep.readCSimpleExpression(element.csimple); |
| } |
| if (element?.exchangeProperty !== undefined) { |
| def.exchangeProperty = CamelDefinitionYamlStep.readExchangePropertyExpression(element.exchangeProperty); |
| } |
| if (element?.jsonpath !== undefined) { |
| def.jsonpath = CamelDefinitionYamlStep.readJsonPathExpression(element.jsonpath); |
| } |
| if (element?.header !== undefined) { |
| def.header = CamelDefinitionYamlStep.readHeaderExpression(element.header); |
| } |
| if (element?.joor !== undefined) { |
| def.joor = CamelDefinitionYamlStep.readJoorExpression(element.joor); |
| } |
| if (element?.xtokenize !== undefined) { |
| def.xtokenize = CamelDefinitionYamlStep.readXMLTokenizerExpression(element.xtokenize); |
| } |
| |
| return def; |
| } |
| |
| static readFaultToleranceConfigurationDefinition = (element: any): FaultToleranceConfigurationDefinition => { |
| |
| const def = element ? new FaultToleranceConfigurationDefinition({...element}) : new FaultToleranceConfigurationDefinition(); |
| |
| return def; |
| } |
| |
| static readFilterDefinition = (element: any): FilterDefinition => { |
| |
| const def = element ? new FilterDefinition({...element}) : new FilterDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readFinallyDefinition = (element: any): FinallyDefinition => { |
| |
| const def = element ? new FinallyDefinition({...element}) : new FinallyDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readFromDefinition = (element: any): FromDefinition => { |
| if (element && typeof element === 'string') element = { uri: element}; |
| const def = element ? new FromDefinition({...element}) : new FromDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readGlobalOptionDefinition = (element: any): GlobalOptionDefinition => { |
| |
| const def = element ? new GlobalOptionDefinition({...element}) : new GlobalOptionDefinition(); |
| |
| return def; |
| } |
| |
| static readGlobalOptionsDefinition = (element: any): GlobalOptionsDefinition => { |
| |
| const def = element ? new GlobalOptionsDefinition({...element}) : new GlobalOptionsDefinition(); |
| def.globalOption = element && element?.globalOption ? element?.globalOption.map((x:any) => CamelDefinitionYamlStep.readGlobalOptionDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readIdempotentConsumerDefinition = (element: any): IdempotentConsumerDefinition => { |
| |
| const def = element ? new IdempotentConsumerDefinition({...element}) : new IdempotentConsumerDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readInOnlyDefinition = (element: any): InOnlyDefinition => { |
| if (element && typeof element === 'string') element = {uri: element}; |
| const def = element ? new InOnlyDefinition({...element}) : new InOnlyDefinition(); |
| |
| return def; |
| } |
| |
| static readInOutDefinition = (element: any): InOutDefinition => { |
| if (element && typeof element === 'string') element = {uri: element}; |
| const def = element ? new InOutDefinition({...element}) : new InOutDefinition(); |
| |
| return def; |
| } |
| |
| static readInputTypeDefinition = (element: any): InputTypeDefinition => { |
| |
| const def = element ? new InputTypeDefinition({...element}) : new InputTypeDefinition(); |
| |
| return def; |
| } |
| |
| static readInterceptDefinition = (element: any): InterceptDefinition => { |
| |
| const def = element ? new InterceptDefinition({...element}) : new InterceptDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readInterceptFromDefinition = (element: any): InterceptFromDefinition => { |
| |
| const def = element ? new InterceptFromDefinition({...element}) : new InterceptFromDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readInterceptSendToEndpointDefinition = (element: any): InterceptSendToEndpointDefinition => { |
| if (element && typeof element === 'string') element = {uri: element}; |
| const def = element ? new InterceptSendToEndpointDefinition({...element}) : new InterceptSendToEndpointDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readKameletDefinition = (element: any): KameletDefinition => { |
| if (element && typeof element === 'string') element = {name: element}; |
| const def = element ? new KameletDefinition({...element}) : new KameletDefinition(); |
| |
| return def; |
| } |
| |
| static readLoadBalanceDefinition = (element: any): LoadBalanceDefinition => { |
| |
| const def = element ? new LoadBalanceDefinition({...element}) : new LoadBalanceDefinition(); |
| if (element?.random !== undefined) { |
| def.random = CamelDefinitionYamlStep.readRandomLoadBalancerDefinition(element.random); |
| } |
| if (element?.customLoadBalancer !== undefined) { |
| def.customLoadBalancer = CamelDefinitionYamlStep.readCustomLoadBalancerDefinition(element.customLoadBalancer); |
| } |
| if (element?.failover !== undefined) { |
| def.failover = CamelDefinitionYamlStep.readFailoverLoadBalancerDefinition(element.failover); |
| } |
| if (element?.sticky !== undefined) { |
| def.sticky = CamelDefinitionYamlStep.readStickyLoadBalancerDefinition(element.sticky); |
| } |
| if (element?.topic !== undefined) { |
| def.topic = CamelDefinitionYamlStep.readTopicLoadBalancerDefinition(element.topic); |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| if (element?.weighted !== undefined) { |
| def.weighted = CamelDefinitionYamlStep.readWeightedLoadBalancerDefinition(element.weighted); |
| } |
| if (element?.roundRobin !== undefined) { |
| def.roundRobin = CamelDefinitionYamlStep.readRoundRobinLoadBalancerDefinition(element.roundRobin); |
| } |
| |
| return def; |
| } |
| |
| static readLogDefinition = (element: any): LogDefinition => { |
| if (element && typeof element === 'string') element = {message: element}; |
| const def = element ? new LogDefinition({...element}) : new LogDefinition(); |
| |
| return def; |
| } |
| |
| static readLoopDefinition = (element: any): LoopDefinition => { |
| |
| const def = element ? new LoopDefinition({...element}) : new LoopDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readMarshalDefinition = (element: any): MarshalDefinition => { |
| |
| const def = element ? new MarshalDefinition({...element}) : new MarshalDefinition(); |
| if (element?.univocityCsv !== undefined) { |
| def.univocityCsv = CamelDefinitionYamlStep.readUniVocityCsvDataFormat(element.univocityCsv); |
| } |
| if (element?.protobuf !== undefined) { |
| def.protobuf = CamelDefinitionYamlStep.readProtobufDataFormat(element.protobuf); |
| } |
| if (element?.tarFile !== undefined) { |
| def.tarFile = CamelDefinitionYamlStep.readTarFileDataFormat(element.tarFile); |
| } |
| if (element?.tidyMarkup !== undefined) { |
| def.tidyMarkup = CamelDefinitionYamlStep.readTidyMarkupDataFormat(element.tidyMarkup); |
| } |
| if (element?.csv !== undefined) { |
| def.csv = CamelDefinitionYamlStep.readCsvDataFormat(element.csv); |
| } |
| if (element?.base64 !== undefined) { |
| def.base64 = CamelDefinitionYamlStep.readBase64DataFormat(element.base64); |
| } |
| if (element?.zipDeflater !== undefined) { |
| def.zipDeflater = CamelDefinitionYamlStep.readZipDeflaterDataFormat(element.zipDeflater); |
| } |
| if (element?.bindy !== undefined) { |
| def.bindy = CamelDefinitionYamlStep.readBindyDataFormat(element.bindy); |
| } |
| if (element?.syslog !== undefined) { |
| def.syslog = CamelDefinitionYamlStep.readSyslogDataFormat(element.syslog); |
| } |
| if (element?.zipFile !== undefined) { |
| def.zipFile = CamelDefinitionYamlStep.readZipFileDataFormat(element.zipFile); |
| } |
| if (element?.jaxb !== undefined) { |
| def.jaxb = CamelDefinitionYamlStep.readJaxbDataFormat(element.jaxb); |
| } |
| if (element?.rss !== undefined) { |
| def.rss = CamelDefinitionYamlStep.readRssDataFormat(element.rss); |
| } |
| if (element?.mimeMultipart !== undefined) { |
| def.mimeMultipart = CamelDefinitionYamlStep.readMimeMultipartDataFormat(element.mimeMultipart); |
| } |
| if (element?.asn1 !== undefined) { |
| def.asn1 = CamelDefinitionYamlStep.readASN1DataFormat(element.asn1); |
| } |
| if (element?.pgp !== undefined) { |
| def.pgp = CamelDefinitionYamlStep.readPGPDataFormat(element.pgp); |
| } |
| if (element?.thrift !== undefined) { |
| def.thrift = CamelDefinitionYamlStep.readThriftDataFormat(element.thrift); |
| } |
| if (element?.json !== undefined) { |
| def.json = CamelDefinitionYamlStep.readJsonDataFormat(element.json); |
| } |
| if (element?.lzf !== undefined) { |
| def.lzf = CamelDefinitionYamlStep.readLZFDataFormat(element.lzf); |
| } |
| if (element?.fhirXml !== undefined) { |
| def.fhirXml = CamelDefinitionYamlStep.readFhirXmlDataFormat(element.fhirXml); |
| } |
| if (element?.barcode !== undefined) { |
| def.barcode = CamelDefinitionYamlStep.readBarcodeDataFormat(element.barcode); |
| } |
| if (element?.avro !== undefined) { |
| def.avro = CamelDefinitionYamlStep.readAvroDataFormat(element.avro); |
| } |
| if (element?.yaml !== undefined) { |
| def.yaml = CamelDefinitionYamlStep.readYAMLDataFormat(element.yaml); |
| } |
| if (element?.fhirJson !== undefined) { |
| def.fhirJson = CamelDefinitionYamlStep.readFhirJsonDataFormat(element.fhirJson); |
| } |
| if (element?.any23 !== undefined) { |
| def.any23 = CamelDefinitionYamlStep.readAny23DataFormat(element.any23); |
| } |
| if (element?.custom !== undefined) { |
| def.custom = CamelDefinitionYamlStep.readCustomDataFormat(element.custom); |
| } |
| if (element?.flatpack !== undefined) { |
| def.flatpack = CamelDefinitionYamlStep.readFlatpackDataFormat(element.flatpack); |
| } |
| if (element?.cbor !== undefined) { |
| def.cbor = CamelDefinitionYamlStep.readCBORDataFormat(element.cbor); |
| } |
| if (element?.crypto !== undefined) { |
| def.crypto = CamelDefinitionYamlStep.readCryptoDataFormat(element.crypto); |
| } |
| if (element?.univocityTsv !== undefined) { |
| def.univocityTsv = CamelDefinitionYamlStep.readUniVocityTsvDataFormat(element.univocityTsv); |
| } |
| if (element?.hl7 !== undefined) { |
| def.hl7 = CamelDefinitionYamlStep.readHL7DataFormat(element.hl7); |
| } |
| if (element?.jsonApi !== undefined) { |
| def.jsonApi = CamelDefinitionYamlStep.readJsonApiDataFormat(element.jsonApi); |
| } |
| if (element?.xmlSecurity !== undefined) { |
| def.xmlSecurity = CamelDefinitionYamlStep.readXMLSecurityDataFormat(element.xmlSecurity); |
| } |
| if (element?.ical !== undefined) { |
| def.ical = CamelDefinitionYamlStep.readIcalDataFormat(element.ical); |
| } |
| if (element?.univocityFixed !== undefined) { |
| def.univocityFixed = CamelDefinitionYamlStep.readUniVocityFixedDataFormat(element.univocityFixed); |
| } |
| if (element?.jacksonXml !== undefined) { |
| def.jacksonXml = CamelDefinitionYamlStep.readJacksonXMLDataFormat(element.jacksonXml); |
| } |
| if (element?.grok !== undefined) { |
| def.grok = CamelDefinitionYamlStep.readGrokDataFormat(element.grok); |
| } |
| if (element?.xstream !== undefined) { |
| def.xstream = CamelDefinitionYamlStep.readXStreamDataFormat(element.xstream); |
| } |
| if (element?.gzipDeflater !== undefined) { |
| def.gzipDeflater = CamelDefinitionYamlStep.readGzipDeflaterDataFormat(element.gzipDeflater); |
| } |
| if (element?.soap !== undefined) { |
| def.soap = CamelDefinitionYamlStep.readSoapDataFormat(element.soap); |
| } |
| |
| return def; |
| } |
| |
| static readMulticastDefinition = (element: any): MulticastDefinition => { |
| |
| const def = element ? new MulticastDefinition({...element}) : new MulticastDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readOnCompletionDefinition = (element: any): OnCompletionDefinition => { |
| |
| const def = element ? new OnCompletionDefinition({...element}) : new OnCompletionDefinition(); |
| if (element?.onWhen !== undefined) { |
| def.onWhen = CamelDefinitionYamlStep.readWhenDefinition(element.onWhen); |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readOnExceptionDefinition = (element: any): OnExceptionDefinition => { |
| |
| const def = element ? new OnExceptionDefinition({...element}) : new OnExceptionDefinition(); |
| if (element?.retryWhile !== undefined) { |
| def.retryWhile = CamelDefinitionYamlStep.readExpressionSubElementDefinition(element.retryWhile); |
| } |
| if (element?.redeliveryPolicy !== undefined) { |
| def.redeliveryPolicy = CamelDefinitionYamlStep.readRedeliveryPolicyDefinition(element.redeliveryPolicy); |
| } |
| if (element?.handled !== undefined) { |
| def.handled = CamelDefinitionYamlStep.readExpressionSubElementDefinition(element.handled); |
| } |
| if (element?.onWhen !== undefined) { |
| def.onWhen = CamelDefinitionYamlStep.readWhenDefinition(element.onWhen); |
| } |
| if (element?.continued !== undefined) { |
| def.continued = CamelDefinitionYamlStep.readExpressionSubElementDefinition(element.continued); |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readOnFallbackDefinition = (element: any): OnFallbackDefinition => { |
| |
| const def = element ? new OnFallbackDefinition({...element}) : new OnFallbackDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readOptimisticLockRetryPolicyDefinition = (element: any): OptimisticLockRetryPolicyDefinition => { |
| |
| const def = element ? new OptimisticLockRetryPolicyDefinition({...element}) : new OptimisticLockRetryPolicyDefinition(); |
| |
| return def; |
| } |
| |
| static readOtherwiseDefinition = (element: any): OtherwiseDefinition => { |
| |
| const def = element ? new OtherwiseDefinition({...element}) : new OtherwiseDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readOutputDefinition = (element: any): OutputDefinition => { |
| |
| const def = element ? new OutputDefinition({...element}) : new OutputDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readOutputTypeDefinition = (element: any): OutputTypeDefinition => { |
| |
| const def = element ? new OutputTypeDefinition({...element}) : new OutputTypeDefinition(); |
| |
| return def; |
| } |
| |
| static readPackageScanDefinition = (element: any): PackageScanDefinition => { |
| |
| const def = element ? new PackageScanDefinition({...element}) : new PackageScanDefinition(); |
| |
| return def; |
| } |
| |
| static readPausableDefinition = (element: any): PausableDefinition => { |
| |
| const def = element ? new PausableDefinition({...element}) : new PausableDefinition(); |
| |
| return def; |
| } |
| |
| static readPipelineDefinition = (element: any): PipelineDefinition => { |
| |
| const def = element ? new PipelineDefinition({...element}) : new PipelineDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readPolicyDefinition = (element: any): PolicyDefinition => { |
| |
| const def = element ? new PolicyDefinition({...element}) : new PolicyDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readPollEnrichDefinition = (element: any): PollEnrichDefinition => { |
| |
| const def = element ? new PollEnrichDefinition({...element}) : new PollEnrichDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readProcessDefinition = (element: any): ProcessDefinition => { |
| |
| const def = element ? new ProcessDefinition({...element}) : new ProcessDefinition(); |
| |
| return def; |
| } |
| |
| static readPropertyDefinition = (element: any): PropertyDefinition => { |
| |
| const def = element ? new PropertyDefinition({...element}) : new PropertyDefinition(); |
| |
| return def; |
| } |
| |
| static readPropertyExpressionDefinition = (element: any): PropertyExpressionDefinition => { |
| |
| const def = element ? new PropertyExpressionDefinition({...element}) : new PropertyExpressionDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readRecipientListDefinition = (element: any): RecipientListDefinition => { |
| |
| const def = element ? new RecipientListDefinition({...element}) : new RecipientListDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readRedeliveryPolicyDefinition = (element: any): RedeliveryPolicyDefinition => { |
| |
| const def = element ? new RedeliveryPolicyDefinition({...element}) : new RedeliveryPolicyDefinition(); |
| |
| return def; |
| } |
| |
| static readRemoveHeaderDefinition = (element: any): RemoveHeaderDefinition => { |
| if (element && typeof element === 'string') element = {name: element}; |
| const def = element ? new RemoveHeaderDefinition({...element}) : new RemoveHeaderDefinition(); |
| |
| return def; |
| } |
| |
| static readRemoveHeadersDefinition = (element: any): RemoveHeadersDefinition => { |
| if (element && typeof element === 'string') element = {pattern: element}; |
| const def = element ? new RemoveHeadersDefinition({...element}) : new RemoveHeadersDefinition(); |
| |
| return def; |
| } |
| |
| static readRemovePropertiesDefinition = (element: any): RemovePropertiesDefinition => { |
| if (element && typeof element === 'string') element = {pattern: element}; |
| const def = element ? new RemovePropertiesDefinition({...element}) : new RemovePropertiesDefinition(); |
| |
| return def; |
| } |
| |
| static readRemovePropertyDefinition = (element: any): RemovePropertyDefinition => { |
| if (element && typeof element === 'string') element = {name: element}; |
| const def = element ? new RemovePropertyDefinition({...element}) : new RemovePropertyDefinition(); |
| |
| return def; |
| } |
| |
| static readResequenceDefinition = (element: any): ResequenceDefinition => { |
| |
| const def = element ? new ResequenceDefinition({...element}) : new ResequenceDefinition(); |
| if (element?.streamConfig !== undefined) { |
| def.streamConfig = CamelDefinitionYamlStep.readStreamResequencerConfig(element.streamConfig); |
| } |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| if (element?.batchConfig !== undefined) { |
| def.batchConfig = CamelDefinitionYamlStep.readBatchResequencerConfig(element.batchConfig); |
| } |
| |
| return def; |
| } |
| |
| static readResilience4jConfigurationDefinition = (element: any): Resilience4jConfigurationDefinition => { |
| |
| const def = element ? new Resilience4jConfigurationDefinition({...element}) : new Resilience4jConfigurationDefinition(); |
| |
| return def; |
| } |
| |
| static readRestContextRefDefinition = (element: any): RestContextRefDefinition => { |
| if (element && typeof element === 'string') element = {ref: element}; |
| const def = element ? new RestContextRefDefinition({...element}) : new RestContextRefDefinition(); |
| |
| return def; |
| } |
| |
| static readResumableDefinition = (element: any): ResumableDefinition => { |
| |
| const def = element ? new ResumableDefinition({...element}) : new ResumableDefinition(); |
| |
| return def; |
| } |
| |
| static readRollbackDefinition = (element: any): RollbackDefinition => { |
| |
| const def = element ? new RollbackDefinition({...element}) : new RollbackDefinition(); |
| |
| return def; |
| } |
| |
| static readRouteBuilderDefinition = (element: any): RouteBuilderDefinition => { |
| if (element && typeof element === 'string') element = {ref: element}; |
| const def = element ? new RouteBuilderDefinition({...element}) : new RouteBuilderDefinition(); |
| |
| return def; |
| } |
| |
| static readRouteConfigurationContextRefDefinition = (element: any): RouteConfigurationContextRefDefinition => { |
| if (element && typeof element === 'string') element = {ref: element}; |
| const def = element ? new RouteConfigurationContextRefDefinition({...element}) : new RouteConfigurationContextRefDefinition(); |
| |
| return def; |
| } |
| |
| static readRouteConfigurationDefinition = (element: any): RouteConfigurationDefinition => { |
| |
| const def = element ? new RouteConfigurationDefinition({...element}) : new RouteConfigurationDefinition(); |
| def.onCompletion = element && element?.onCompletion ? element?.onCompletion.map((x:any) => CamelDefinitionYamlStep.readOnCompletionDefinition(x)) :[]; |
| def.interceptSendToEndpoint = element && element?.interceptSendToEndpoint ? element?.interceptSendToEndpoint.map((x:any) => CamelDefinitionYamlStep.readInterceptSendToEndpointDefinition(x)) :[]; |
| def.intercept = element && element?.intercept ? element?.intercept.map((x:any) => CamelDefinitionYamlStep.readInterceptDefinition(x)) :[]; |
| if (element?.errorHandler !== undefined) { |
| def.errorHandler = CamelDefinitionYamlStep.readErrorHandlerDefinition(element.errorHandler); |
| } |
| def.onException = element && element?.onException ? element?.onException.map((x:any) => CamelDefinitionYamlStep.readOnExceptionDefinition(x)) :[]; |
| def.interceptFrom = element && element?.interceptFrom ? element?.interceptFrom.map((x:any) => CamelDefinitionYamlStep.readInterceptFromDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readRouteContextRefDefinition = (element: any): RouteContextRefDefinition => { |
| if (element && typeof element === 'string') element = {ref: element}; |
| const def = element ? new RouteContextRefDefinition({...element}) : new RouteContextRefDefinition(); |
| |
| return def; |
| } |
| |
| static readRouteDefinition = (element: any): RouteDefinition => { |
| |
| const def = element ? new RouteDefinition({...element}) : new RouteDefinition(); |
| if (element?.from !== undefined) { |
| def.from = CamelDefinitionYamlStep.readFromDefinition(element.from); |
| } |
| |
| return def; |
| } |
| |
| static readRouteTemplateBeanDefinition = (element: any): RouteTemplateBeanDefinition => { |
| |
| const def = element ? new RouteTemplateBeanDefinition({...element}) : new RouteTemplateBeanDefinition(); |
| def.property = element && element?.property ? element?.property.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readRouteTemplateDefinition = (element: any): RouteTemplateDefinition => { |
| |
| const def = element ? new RouteTemplateDefinition({...element}) : new RouteTemplateDefinition(); |
| def.beans = element && element?.beans ? element?.beans.map((x:any) => CamelDefinitionYamlStep.readNamedBeanDefinition(x)) :[]; |
| if (element?.from !== undefined) { |
| def.from = CamelDefinitionYamlStep.readFromDefinition(element.from); |
| } |
| def.parameters = element && element?.parameters ? element?.parameters.map((x:any) => CamelDefinitionYamlStep.readRouteTemplateParameterDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readRouteTemplateParameterDefinition = (element: any): RouteTemplateParameterDefinition => { |
| |
| const def = element ? new RouteTemplateParameterDefinition({...element}) : new RouteTemplateParameterDefinition(); |
| |
| return def; |
| } |
| |
| static readRoutingSlipDefinition = (element: any): RoutingSlipDefinition => { |
| |
| const def = element ? new RoutingSlipDefinition({...element}) : new RoutingSlipDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readSagaActionUriDefinition = (element: any): SagaActionUriDefinition => { |
| if (element && typeof element === 'string') element = {uri: element}; |
| const def = element ? new SagaActionUriDefinition({...element}) : new SagaActionUriDefinition(); |
| |
| return def; |
| } |
| |
| static readSagaDefinition = (element: any): SagaDefinition => { |
| |
| const def = element ? new SagaDefinition({...element}) : new SagaDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| def.option = element && element?.option ? element?.option.map((x:any) => CamelDefinitionYamlStep.readPropertyExpressionDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readSamplingDefinition = (element: any): SamplingDefinition => { |
| |
| const def = element ? new SamplingDefinition({...element}) : new SamplingDefinition(); |
| |
| return def; |
| } |
| |
| static readScriptDefinition = (element: any): ScriptDefinition => { |
| |
| const def = element ? new ScriptDefinition({...element}) : new ScriptDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readSetBodyDefinition = (element: any): SetBodyDefinition => { |
| |
| const def = element ? new SetBodyDefinition({...element}) : new SetBodyDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readSetExchangePatternDefinition = (element: any): SetExchangePatternDefinition => { |
| if (element && typeof element === 'string') element = {pattern: element}; |
| const def = element ? new SetExchangePatternDefinition({...element}) : new SetExchangePatternDefinition(); |
| |
| return def; |
| } |
| |
| static readSetHeaderDefinition = (element: any): SetHeaderDefinition => { |
| |
| const def = element ? new SetHeaderDefinition({...element}) : new SetHeaderDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readSetPropertyDefinition = (element: any): SetPropertyDefinition => { |
| |
| const def = element ? new SetPropertyDefinition({...element}) : new SetPropertyDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readSortDefinition = (element: any): SortDefinition => { |
| |
| const def = element ? new SortDefinition({...element}) : new SortDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readSplitDefinition = (element: any): SplitDefinition => { |
| |
| const def = element ? new SplitDefinition({...element}) : new SplitDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readStepDefinition = (element: any): StepDefinition => { |
| |
| const def = element ? new StepDefinition({...element}) : new StepDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readStopDefinition = (element: any): StopDefinition => { |
| |
| const def = element ? new StopDefinition({...element}) : new StopDefinition(); |
| |
| return def; |
| } |
| |
| static readTemplatedRouteBeanDefinition = (element: any): TemplatedRouteBeanDefinition => { |
| |
| const def = element ? new TemplatedRouteBeanDefinition({...element}) : new TemplatedRouteBeanDefinition(); |
| def.property = element && element?.property ? element?.property.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readTemplatedRouteDefinition = (element: any): TemplatedRouteDefinition => { |
| |
| const def = element ? new TemplatedRouteDefinition({...element}) : new TemplatedRouteDefinition(); |
| def.beans = element && element?.beans ? element?.beans.map((x:any) => CamelDefinitionYamlStep.readNamedBeanDefinition(x)) :[]; |
| def.parameters = element && element?.parameters ? element?.parameters.map((x:any) => CamelDefinitionYamlStep.readTemplatedRouteParameterDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readTemplatedRouteParameterDefinition = (element: any): TemplatedRouteParameterDefinition => { |
| |
| const def = element ? new TemplatedRouteParameterDefinition({...element}) : new TemplatedRouteParameterDefinition(); |
| |
| return def; |
| } |
| |
| static readThreadPoolProfileDefinition = (element: any): ThreadPoolProfileDefinition => { |
| |
| const def = element ? new ThreadPoolProfileDefinition({...element}) : new ThreadPoolProfileDefinition(); |
| |
| return def; |
| } |
| |
| static readThreadsDefinition = (element: any): ThreadsDefinition => { |
| |
| const def = element ? new ThreadsDefinition({...element}) : new ThreadsDefinition(); |
| |
| return def; |
| } |
| |
| static readThrottleDefinition = (element: any): ThrottleDefinition => { |
| |
| const def = element ? new ThrottleDefinition({...element}) : new ThrottleDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| if (element?.correlationExpression !== undefined) { |
| def.correlationExpression = CamelDefinitionYamlStep.readExpressionSubElementDefinition(element.correlationExpression); |
| } |
| |
| return def; |
| } |
| |
| static readThrowExceptionDefinition = (element: any): ThrowExceptionDefinition => { |
| |
| const def = element ? new ThrowExceptionDefinition({...element}) : new ThrowExceptionDefinition(); |
| |
| return def; |
| } |
| |
| static readToDefinition = (element: any): ToDefinition => { |
| if (element && typeof element === 'string') element = {uri: element}; |
| const def = element ? new ToDefinition({...element}) : new ToDefinition(); |
| |
| return def; |
| } |
| |
| static readToDynamicDefinition = (element: any): ToDynamicDefinition => { |
| if (element && typeof element === 'string') element = {uri: element}; |
| const def = element ? new ToDynamicDefinition({...element}) : new ToDynamicDefinition(); |
| |
| return def; |
| } |
| |
| static readTransactedDefinition = (element: any): TransactedDefinition => { |
| |
| const def = element ? new TransactedDefinition({...element}) : new TransactedDefinition(); |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readTransformDefinition = (element: any): TransformDefinition => { |
| |
| const def = element ? new TransformDefinition({...element}) : new TransformDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readTryDefinition = (element: any): TryDefinition => { |
| |
| const def = element ? new TryDefinition({...element}) : new TryDefinition(); |
| if (element?.doFinally !== undefined) { |
| def.doFinally = CamelDefinitionYamlStep.readFinallyDefinition(element.doFinally); |
| } |
| def.doCatch = element && element?.doCatch ? element?.doCatch.map((x:any) => CamelDefinitionYamlStep.readCatchDefinition(x)) :[]; |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readUnmarshalDefinition = (element: any): UnmarshalDefinition => { |
| |
| const def = element ? new UnmarshalDefinition({...element}) : new UnmarshalDefinition(); |
| if (element?.univocityCsv !== undefined) { |
| def.univocityCsv = CamelDefinitionYamlStep.readUniVocityCsvDataFormat(element.univocityCsv); |
| } |
| if (element?.protobuf !== undefined) { |
| def.protobuf = CamelDefinitionYamlStep.readProtobufDataFormat(element.protobuf); |
| } |
| if (element?.tarFile !== undefined) { |
| def.tarFile = CamelDefinitionYamlStep.readTarFileDataFormat(element.tarFile); |
| } |
| if (element?.tidyMarkup !== undefined) { |
| def.tidyMarkup = CamelDefinitionYamlStep.readTidyMarkupDataFormat(element.tidyMarkup); |
| } |
| if (element?.csv !== undefined) { |
| def.csv = CamelDefinitionYamlStep.readCsvDataFormat(element.csv); |
| } |
| if (element?.base64 !== undefined) { |
| def.base64 = CamelDefinitionYamlStep.readBase64DataFormat(element.base64); |
| } |
| if (element?.zipDeflater !== undefined) { |
| def.zipDeflater = CamelDefinitionYamlStep.readZipDeflaterDataFormat(element.zipDeflater); |
| } |
| if (element?.bindy !== undefined) { |
| def.bindy = CamelDefinitionYamlStep.readBindyDataFormat(element.bindy); |
| } |
| if (element?.syslog !== undefined) { |
| def.syslog = CamelDefinitionYamlStep.readSyslogDataFormat(element.syslog); |
| } |
| if (element?.zipFile !== undefined) { |
| def.zipFile = CamelDefinitionYamlStep.readZipFileDataFormat(element.zipFile); |
| } |
| if (element?.jaxb !== undefined) { |
| def.jaxb = CamelDefinitionYamlStep.readJaxbDataFormat(element.jaxb); |
| } |
| if (element?.rss !== undefined) { |
| def.rss = CamelDefinitionYamlStep.readRssDataFormat(element.rss); |
| } |
| if (element?.mimeMultipart !== undefined) { |
| def.mimeMultipart = CamelDefinitionYamlStep.readMimeMultipartDataFormat(element.mimeMultipart); |
| } |
| if (element?.asn1 !== undefined) { |
| def.asn1 = CamelDefinitionYamlStep.readASN1DataFormat(element.asn1); |
| } |
| if (element?.pgp !== undefined) { |
| def.pgp = CamelDefinitionYamlStep.readPGPDataFormat(element.pgp); |
| } |
| if (element?.thrift !== undefined) { |
| def.thrift = CamelDefinitionYamlStep.readThriftDataFormat(element.thrift); |
| } |
| if (element?.json !== undefined) { |
| def.json = CamelDefinitionYamlStep.readJsonDataFormat(element.json); |
| } |
| if (element?.lzf !== undefined) { |
| def.lzf = CamelDefinitionYamlStep.readLZFDataFormat(element.lzf); |
| } |
| if (element?.fhirXml !== undefined) { |
| def.fhirXml = CamelDefinitionYamlStep.readFhirXmlDataFormat(element.fhirXml); |
| } |
| if (element?.barcode !== undefined) { |
| def.barcode = CamelDefinitionYamlStep.readBarcodeDataFormat(element.barcode); |
| } |
| if (element?.avro !== undefined) { |
| def.avro = CamelDefinitionYamlStep.readAvroDataFormat(element.avro); |
| } |
| if (element?.yaml !== undefined) { |
| def.yaml = CamelDefinitionYamlStep.readYAMLDataFormat(element.yaml); |
| } |
| if (element?.fhirJson !== undefined) { |
| def.fhirJson = CamelDefinitionYamlStep.readFhirJsonDataFormat(element.fhirJson); |
| } |
| if (element?.any23 !== undefined) { |
| def.any23 = CamelDefinitionYamlStep.readAny23DataFormat(element.any23); |
| } |
| if (element?.custom !== undefined) { |
| def.custom = CamelDefinitionYamlStep.readCustomDataFormat(element.custom); |
| } |
| if (element?.flatpack !== undefined) { |
| def.flatpack = CamelDefinitionYamlStep.readFlatpackDataFormat(element.flatpack); |
| } |
| if (element?.cbor !== undefined) { |
| def.cbor = CamelDefinitionYamlStep.readCBORDataFormat(element.cbor); |
| } |
| if (element?.crypto !== undefined) { |
| def.crypto = CamelDefinitionYamlStep.readCryptoDataFormat(element.crypto); |
| } |
| if (element?.univocityTsv !== undefined) { |
| def.univocityTsv = CamelDefinitionYamlStep.readUniVocityTsvDataFormat(element.univocityTsv); |
| } |
| if (element?.hl7 !== undefined) { |
| def.hl7 = CamelDefinitionYamlStep.readHL7DataFormat(element.hl7); |
| } |
| if (element?.jsonApi !== undefined) { |
| def.jsonApi = CamelDefinitionYamlStep.readJsonApiDataFormat(element.jsonApi); |
| } |
| if (element?.xmlSecurity !== undefined) { |
| def.xmlSecurity = CamelDefinitionYamlStep.readXMLSecurityDataFormat(element.xmlSecurity); |
| } |
| if (element?.ical !== undefined) { |
| def.ical = CamelDefinitionYamlStep.readIcalDataFormat(element.ical); |
| } |
| if (element?.univocityFixed !== undefined) { |
| def.univocityFixed = CamelDefinitionYamlStep.readUniVocityFixedDataFormat(element.univocityFixed); |
| } |
| if (element?.jacksonXml !== undefined) { |
| def.jacksonXml = CamelDefinitionYamlStep.readJacksonXMLDataFormat(element.jacksonXml); |
| } |
| if (element?.grok !== undefined) { |
| def.grok = CamelDefinitionYamlStep.readGrokDataFormat(element.grok); |
| } |
| if (element?.xstream !== undefined) { |
| def.xstream = CamelDefinitionYamlStep.readXStreamDataFormat(element.xstream); |
| } |
| if (element?.gzipDeflater !== undefined) { |
| def.gzipDeflater = CamelDefinitionYamlStep.readGzipDeflaterDataFormat(element.gzipDeflater); |
| } |
| if (element?.soap !== undefined) { |
| def.soap = CamelDefinitionYamlStep.readSoapDataFormat(element.soap); |
| } |
| |
| return def; |
| } |
| |
| static readValidateDefinition = (element: any): ValidateDefinition => { |
| |
| const def = element ? new ValidateDefinition({...element}) : new ValidateDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readWhenDefinition = (element: any): WhenDefinition => { |
| |
| const def = element ? new WhenDefinition({...element}) : new WhenDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readWhenSkipSendToEndpointDefinition = (element: any): WhenSkipSendToEndpointDefinition => { |
| |
| const def = element ? new WhenSkipSendToEndpointDefinition({...element}) : new WhenSkipSendToEndpointDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| def.steps = CamelDefinitionYamlStep.readSteps(element?.steps); |
| |
| return def; |
| } |
| |
| static readWireTapDefinition = (element: any): WireTapDefinition => { |
| |
| const def = element ? new WireTapDefinition({...element}) : new WireTapDefinition(); |
| |
| return def; |
| } |
| |
| static readBlacklistServiceCallServiceFilterConfiguration = (element: any): BlacklistServiceCallServiceFilterConfiguration => { |
| |
| const def = element ? new BlacklistServiceCallServiceFilterConfiguration({...element}) : new BlacklistServiceCallServiceFilterConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readCachingServiceCallServiceDiscoveryConfiguration = (element: any): CachingServiceCallServiceDiscoveryConfiguration => { |
| |
| const def = element ? new CachingServiceCallServiceDiscoveryConfiguration({...element}) : new CachingServiceCallServiceDiscoveryConfiguration(); |
| if (element?.dnsServiceDiscovery !== undefined) { |
| def.dnsServiceDiscovery = CamelDefinitionYamlStep.readDnsServiceCallServiceDiscoveryConfiguration(element.dnsServiceDiscovery); |
| } |
| if (element?.kubernetesServiceDiscovery !== undefined) { |
| def.kubernetesServiceDiscovery = CamelDefinitionYamlStep.readKubernetesServiceCallServiceDiscoveryConfiguration(element.kubernetesServiceDiscovery); |
| } |
| if (element?.consulServiceDiscovery !== undefined) { |
| def.consulServiceDiscovery = CamelDefinitionYamlStep.readConsulServiceCallServiceDiscoveryConfiguration(element.consulServiceDiscovery); |
| } |
| if (element?.staticServiceDiscovery !== undefined) { |
| def.staticServiceDiscovery = CamelDefinitionYamlStep.readStaticServiceCallServiceDiscoveryConfiguration(element.staticServiceDiscovery); |
| } |
| if (element?.combinedServiceDiscovery !== undefined) { |
| def.combinedServiceDiscovery = CamelDefinitionYamlStep.readCombinedServiceCallServiceDiscoveryConfiguration(element.combinedServiceDiscovery); |
| } |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readCombinedServiceCallServiceDiscoveryConfiguration = (element: any): CombinedServiceCallServiceDiscoveryConfiguration => { |
| |
| const def = element ? new CombinedServiceCallServiceDiscoveryConfiguration({...element}) : new CombinedServiceCallServiceDiscoveryConfiguration(); |
| if (element?.cachingServiceDiscovery !== undefined) { |
| def.cachingServiceDiscovery = CamelDefinitionYamlStep.readCachingServiceCallServiceDiscoveryConfiguration(element.cachingServiceDiscovery); |
| } |
| if (element?.dnsServiceDiscovery !== undefined) { |
| def.dnsServiceDiscovery = CamelDefinitionYamlStep.readDnsServiceCallServiceDiscoveryConfiguration(element.dnsServiceDiscovery); |
| } |
| if (element?.kubernetesServiceDiscovery !== undefined) { |
| def.kubernetesServiceDiscovery = CamelDefinitionYamlStep.readKubernetesServiceCallServiceDiscoveryConfiguration(element.kubernetesServiceDiscovery); |
| } |
| if (element?.consulServiceDiscovery !== undefined) { |
| def.consulServiceDiscovery = CamelDefinitionYamlStep.readConsulServiceCallServiceDiscoveryConfiguration(element.consulServiceDiscovery); |
| } |
| if (element?.staticServiceDiscovery !== undefined) { |
| def.staticServiceDiscovery = CamelDefinitionYamlStep.readStaticServiceCallServiceDiscoveryConfiguration(element.staticServiceDiscovery); |
| } |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readCombinedServiceCallServiceFilterConfiguration = (element: any): CombinedServiceCallServiceFilterConfiguration => { |
| |
| const def = element ? new CombinedServiceCallServiceFilterConfiguration({...element}) : new CombinedServiceCallServiceFilterConfiguration(); |
| if (element?.blacklistServiceFilter !== undefined) { |
| def.blacklistServiceFilter = CamelDefinitionYamlStep.readBlacklistServiceCallServiceFilterConfiguration(element.blacklistServiceFilter); |
| } |
| if (element?.passThroughServiceFilter !== undefined) { |
| def.passThroughServiceFilter = CamelDefinitionYamlStep.readPassThroughServiceCallServiceFilterConfiguration(element.passThroughServiceFilter); |
| } |
| if (element?.healthyServiceFilter !== undefined) { |
| def.healthyServiceFilter = CamelDefinitionYamlStep.readHealthyServiceCallServiceFilterConfiguration(element.healthyServiceFilter); |
| } |
| if (element?.customServiceFilter !== undefined) { |
| def.customServiceFilter = CamelDefinitionYamlStep.readCustomServiceCallServiceFilterConfiguration(element.customServiceFilter); |
| } |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readConsulServiceCallServiceDiscoveryConfiguration = (element: any): ConsulServiceCallServiceDiscoveryConfiguration => { |
| |
| const def = element ? new ConsulServiceCallServiceDiscoveryConfiguration({...element}) : new ConsulServiceCallServiceDiscoveryConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readCustomServiceCallServiceFilterConfiguration = (element: any): CustomServiceCallServiceFilterConfiguration => { |
| |
| const def = element ? new CustomServiceCallServiceFilterConfiguration({...element}) : new CustomServiceCallServiceFilterConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readDefaultServiceCallServiceLoadBalancerConfiguration = (element: any): DefaultServiceCallServiceLoadBalancerConfiguration => { |
| |
| const def = element ? new DefaultServiceCallServiceLoadBalancerConfiguration({...element}) : new DefaultServiceCallServiceLoadBalancerConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readDnsServiceCallServiceDiscoveryConfiguration = (element: any): DnsServiceCallServiceDiscoveryConfiguration => { |
| |
| const def = element ? new DnsServiceCallServiceDiscoveryConfiguration({...element}) : new DnsServiceCallServiceDiscoveryConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readHealthyServiceCallServiceFilterConfiguration = (element: any): HealthyServiceCallServiceFilterConfiguration => { |
| |
| const def = element ? new HealthyServiceCallServiceFilterConfiguration({...element}) : new HealthyServiceCallServiceFilterConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readKubernetesServiceCallServiceDiscoveryConfiguration = (element: any): KubernetesServiceCallServiceDiscoveryConfiguration => { |
| |
| const def = element ? new KubernetesServiceCallServiceDiscoveryConfiguration({...element}) : new KubernetesServiceCallServiceDiscoveryConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readPassThroughServiceCallServiceFilterConfiguration = (element: any): PassThroughServiceCallServiceFilterConfiguration => { |
| |
| const def = element ? new PassThroughServiceCallServiceFilterConfiguration({...element}) : new PassThroughServiceCallServiceFilterConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readServiceCallConfigurationDefinition = (element: any): ServiceCallConfigurationDefinition => { |
| |
| const def = element ? new ServiceCallConfigurationDefinition({...element}) : new ServiceCallConfigurationDefinition(); |
| if (element?.defaultLoadBalancer !== undefined) { |
| def.defaultLoadBalancer = CamelDefinitionYamlStep.readDefaultServiceCallServiceLoadBalancerConfiguration(element.defaultLoadBalancer); |
| } |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readServiceCallExpressionConfiguration(element.expression); |
| } |
| if (element?.kubernetesServiceDiscovery !== undefined) { |
| def.kubernetesServiceDiscovery = CamelDefinitionYamlStep.readKubernetesServiceCallServiceDiscoveryConfiguration(element.kubernetesServiceDiscovery); |
| } |
| if (element?.customServiceFilter !== undefined) { |
| def.customServiceFilter = CamelDefinitionYamlStep.readCustomServiceCallServiceFilterConfiguration(element.customServiceFilter); |
| } |
| if (element?.zookeeperServiceDiscovery !== undefined) { |
| def.zookeeperServiceDiscovery = CamelDefinitionYamlStep.readZooKeeperServiceCallServiceDiscoveryConfiguration(element.zookeeperServiceDiscovery); |
| } |
| if (element?.blacklistServiceFilter !== undefined) { |
| def.blacklistServiceFilter = CamelDefinitionYamlStep.readBlacklistServiceCallServiceFilterConfiguration(element.blacklistServiceFilter); |
| } |
| if (element?.passThroughServiceFilter !== undefined) { |
| def.passThroughServiceFilter = CamelDefinitionYamlStep.readPassThroughServiceCallServiceFilterConfiguration(element.passThroughServiceFilter); |
| } |
| if (element?.cachingServiceDiscovery !== undefined) { |
| def.cachingServiceDiscovery = CamelDefinitionYamlStep.readCachingServiceCallServiceDiscoveryConfiguration(element.cachingServiceDiscovery); |
| } |
| if (element?.dnsServiceDiscovery !== undefined) { |
| def.dnsServiceDiscovery = CamelDefinitionYamlStep.readDnsServiceCallServiceDiscoveryConfiguration(element.dnsServiceDiscovery); |
| } |
| if (element?.healthyServiceFilter !== undefined) { |
| def.healthyServiceFilter = CamelDefinitionYamlStep.readHealthyServiceCallServiceFilterConfiguration(element.healthyServiceFilter); |
| } |
| if (element?.combinedServiceFilter !== undefined) { |
| def.combinedServiceFilter = CamelDefinitionYamlStep.readCombinedServiceCallServiceFilterConfiguration(element.combinedServiceFilter); |
| } |
| if (element?.consulServiceDiscovery !== undefined) { |
| def.consulServiceDiscovery = CamelDefinitionYamlStep.readConsulServiceCallServiceDiscoveryConfiguration(element.consulServiceDiscovery); |
| } |
| if (element?.staticServiceDiscovery !== undefined) { |
| def.staticServiceDiscovery = CamelDefinitionYamlStep.readStaticServiceCallServiceDiscoveryConfiguration(element.staticServiceDiscovery); |
| } |
| if (element?.combinedServiceDiscovery !== undefined) { |
| def.combinedServiceDiscovery = CamelDefinitionYamlStep.readCombinedServiceCallServiceDiscoveryConfiguration(element.combinedServiceDiscovery); |
| } |
| |
| return def; |
| } |
| |
| static readServiceCallDefinition = (element: any): ServiceCallDefinition => { |
| if (element && typeof element === 'string') element = {name: element}; |
| const def = element ? new ServiceCallDefinition({...element}) : new ServiceCallDefinition(); |
| if (element?.defaultLoadBalancer !== undefined) { |
| def.defaultLoadBalancer = CamelDefinitionYamlStep.readDefaultServiceCallServiceLoadBalancerConfiguration(element.defaultLoadBalancer); |
| } |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readServiceCallExpressionConfiguration(element.expression); |
| } |
| if (element?.kubernetesServiceDiscovery !== undefined) { |
| def.kubernetesServiceDiscovery = CamelDefinitionYamlStep.readKubernetesServiceCallServiceDiscoveryConfiguration(element.kubernetesServiceDiscovery); |
| } |
| if (element?.customServiceFilter !== undefined) { |
| def.customServiceFilter = CamelDefinitionYamlStep.readCustomServiceCallServiceFilterConfiguration(element.customServiceFilter); |
| } |
| if (element?.zookeeperServiceDiscovery !== undefined) { |
| def.zookeeperServiceDiscovery = CamelDefinitionYamlStep.readZooKeeperServiceCallServiceDiscoveryConfiguration(element.zookeeperServiceDiscovery); |
| } |
| if (element?.blacklistServiceFilter !== undefined) { |
| def.blacklistServiceFilter = CamelDefinitionYamlStep.readBlacklistServiceCallServiceFilterConfiguration(element.blacklistServiceFilter); |
| } |
| if (element?.passThroughServiceFilter !== undefined) { |
| def.passThroughServiceFilter = CamelDefinitionYamlStep.readPassThroughServiceCallServiceFilterConfiguration(element.passThroughServiceFilter); |
| } |
| if (element?.cachingServiceDiscovery !== undefined) { |
| def.cachingServiceDiscovery = CamelDefinitionYamlStep.readCachingServiceCallServiceDiscoveryConfiguration(element.cachingServiceDiscovery); |
| } |
| if (element?.dnsServiceDiscovery !== undefined) { |
| def.dnsServiceDiscovery = CamelDefinitionYamlStep.readDnsServiceCallServiceDiscoveryConfiguration(element.dnsServiceDiscovery); |
| } |
| if (element?.healthyServiceFilter !== undefined) { |
| def.healthyServiceFilter = CamelDefinitionYamlStep.readHealthyServiceCallServiceFilterConfiguration(element.healthyServiceFilter); |
| } |
| if (element?.combinedServiceFilter !== undefined) { |
| def.combinedServiceFilter = CamelDefinitionYamlStep.readCombinedServiceCallServiceFilterConfiguration(element.combinedServiceFilter); |
| } |
| if (element?.consulServiceDiscovery !== undefined) { |
| def.consulServiceDiscovery = CamelDefinitionYamlStep.readConsulServiceCallServiceDiscoveryConfiguration(element.consulServiceDiscovery); |
| } |
| if (element?.staticServiceDiscovery !== undefined) { |
| def.staticServiceDiscovery = CamelDefinitionYamlStep.readStaticServiceCallServiceDiscoveryConfiguration(element.staticServiceDiscovery); |
| } |
| if (element?.combinedServiceDiscovery !== undefined) { |
| def.combinedServiceDiscovery = CamelDefinitionYamlStep.readCombinedServiceCallServiceDiscoveryConfiguration(element.combinedServiceDiscovery); |
| } |
| |
| return def; |
| } |
| |
| static readServiceCallExpressionConfiguration = (element: any): ServiceCallExpressionConfiguration => { |
| |
| const def = element ? new ServiceCallExpressionConfiguration({...element}) : new ServiceCallExpressionConfiguration(); |
| if (element?.expressionType !== undefined) { |
| def.expressionType = CamelDefinitionYamlStep.readExpressionDefinition(element.expressionType); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expressionType = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readServiceCallServiceChooserConfiguration = (element: any): ServiceCallServiceChooserConfiguration => { |
| |
| const def = element ? new ServiceCallServiceChooserConfiguration({...element}) : new ServiceCallServiceChooserConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readServiceCallServiceDiscoveryConfiguration = (element: any): ServiceCallServiceDiscoveryConfiguration => { |
| |
| const def = element ? new ServiceCallServiceDiscoveryConfiguration({...element}) : new ServiceCallServiceDiscoveryConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readServiceCallServiceFilterConfiguration = (element: any): ServiceCallServiceFilterConfiguration => { |
| |
| const def = element ? new ServiceCallServiceFilterConfiguration({...element}) : new ServiceCallServiceFilterConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readServiceCallServiceLoadBalancerConfiguration = (element: any): ServiceCallServiceLoadBalancerConfiguration => { |
| |
| const def = element ? new ServiceCallServiceLoadBalancerConfiguration({...element}) : new ServiceCallServiceLoadBalancerConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readStaticServiceCallServiceDiscoveryConfiguration = (element: any): StaticServiceCallServiceDiscoveryConfiguration => { |
| |
| const def = element ? new StaticServiceCallServiceDiscoveryConfiguration({...element}) : new StaticServiceCallServiceDiscoveryConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readZooKeeperServiceCallServiceDiscoveryConfiguration = (element: any): ZooKeeperServiceCallServiceDiscoveryConfiguration => { |
| |
| const def = element ? new ZooKeeperServiceCallServiceDiscoveryConfiguration({...element}) : new ZooKeeperServiceCallServiceDiscoveryConfiguration(); |
| def.properties = element && element?.properties ? element?.properties.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readBatchResequencerConfig = (element: any): BatchResequencerConfig => { |
| |
| const def = element ? new BatchResequencerConfig({...element}) : new BatchResequencerConfig(); |
| |
| return def; |
| } |
| |
| static readStreamResequencerConfig = (element: any): StreamResequencerConfig => { |
| |
| const def = element ? new StreamResequencerConfig({...element}) : new StreamResequencerConfig(); |
| |
| return def; |
| } |
| |
| static readASN1DataFormat = (element: any): ASN1DataFormat => { |
| |
| const def = element ? new ASN1DataFormat({...element}) : new ASN1DataFormat(); |
| |
| return def; |
| } |
| |
| static readAny23DataFormat = (element: any): Any23DataFormat => { |
| |
| const def = element ? new Any23DataFormat({...element}) : new Any23DataFormat(); |
| def.configuration = element && element?.configuration ? element?.configuration.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readAvroDataFormat = (element: any): AvroDataFormat => { |
| |
| const def = element ? new AvroDataFormat({...element}) : new AvroDataFormat(); |
| |
| return def; |
| } |
| |
| static readBarcodeDataFormat = (element: any): BarcodeDataFormat => { |
| |
| const def = element ? new BarcodeDataFormat({...element}) : new BarcodeDataFormat(); |
| |
| return def; |
| } |
| |
| static readBase64DataFormat = (element: any): Base64DataFormat => { |
| |
| const def = element ? new Base64DataFormat({...element}) : new Base64DataFormat(); |
| |
| return def; |
| } |
| |
| static readBindyDataFormat = (element: any): BindyDataFormat => { |
| |
| const def = element ? new BindyDataFormat({...element}) : new BindyDataFormat(); |
| |
| return def; |
| } |
| |
| static readCBORDataFormat = (element: any): CBORDataFormat => { |
| |
| const def = element ? new CBORDataFormat({...element}) : new CBORDataFormat(); |
| |
| return def; |
| } |
| |
| static readCryptoDataFormat = (element: any): CryptoDataFormat => { |
| |
| const def = element ? new CryptoDataFormat({...element}) : new CryptoDataFormat(); |
| |
| return def; |
| } |
| |
| static readCsvDataFormat = (element: any): CsvDataFormat => { |
| |
| const def = element ? new CsvDataFormat({...element}) : new CsvDataFormat(); |
| |
| return def; |
| } |
| |
| static readCustomDataFormat = (element: any): CustomDataFormat => { |
| if (element && typeof element === 'string') element = {ref: element}; |
| const def = element ? new CustomDataFormat({...element}) : new CustomDataFormat(); |
| |
| return def; |
| } |
| |
| static readDataFormatsDefinition = (element: any): DataFormatsDefinition => { |
| |
| const def = element ? new DataFormatsDefinition({...element}) : new DataFormatsDefinition(); |
| if (element?.univocityCsv !== undefined) { |
| def.univocityCsv = CamelDefinitionYamlStep.readUniVocityCsvDataFormat(element.univocityCsv); |
| } |
| if (element?.protobuf !== undefined) { |
| def.protobuf = CamelDefinitionYamlStep.readProtobufDataFormat(element.protobuf); |
| } |
| if (element?.tarFile !== undefined) { |
| def.tarFile = CamelDefinitionYamlStep.readTarFileDataFormat(element.tarFile); |
| } |
| if (element?.tidyMarkup !== undefined) { |
| def.tidyMarkup = CamelDefinitionYamlStep.readTidyMarkupDataFormat(element.tidyMarkup); |
| } |
| if (element?.csv !== undefined) { |
| def.csv = CamelDefinitionYamlStep.readCsvDataFormat(element.csv); |
| } |
| if (element?.base64 !== undefined) { |
| def.base64 = CamelDefinitionYamlStep.readBase64DataFormat(element.base64); |
| } |
| if (element?.zipDeflater !== undefined) { |
| def.zipDeflater = CamelDefinitionYamlStep.readZipDeflaterDataFormat(element.zipDeflater); |
| } |
| if (element?.bindy !== undefined) { |
| def.bindy = CamelDefinitionYamlStep.readBindyDataFormat(element.bindy); |
| } |
| if (element?.syslog !== undefined) { |
| def.syslog = CamelDefinitionYamlStep.readSyslogDataFormat(element.syslog); |
| } |
| if (element?.zipFile !== undefined) { |
| def.zipFile = CamelDefinitionYamlStep.readZipFileDataFormat(element.zipFile); |
| } |
| if (element?.jaxb !== undefined) { |
| def.jaxb = CamelDefinitionYamlStep.readJaxbDataFormat(element.jaxb); |
| } |
| if (element?.rss !== undefined) { |
| def.rss = CamelDefinitionYamlStep.readRssDataFormat(element.rss); |
| } |
| if (element?.mimeMultipart !== undefined) { |
| def.mimeMultipart = CamelDefinitionYamlStep.readMimeMultipartDataFormat(element.mimeMultipart); |
| } |
| if (element?.asn1 !== undefined) { |
| def.asn1 = CamelDefinitionYamlStep.readASN1DataFormat(element.asn1); |
| } |
| if (element?.pgp !== undefined) { |
| def.pgp = CamelDefinitionYamlStep.readPGPDataFormat(element.pgp); |
| } |
| if (element?.thrift !== undefined) { |
| def.thrift = CamelDefinitionYamlStep.readThriftDataFormat(element.thrift); |
| } |
| if (element?.json !== undefined) { |
| def.json = CamelDefinitionYamlStep.readJsonDataFormat(element.json); |
| } |
| if (element?.lzf !== undefined) { |
| def.lzf = CamelDefinitionYamlStep.readLZFDataFormat(element.lzf); |
| } |
| if (element?.fhirXml !== undefined) { |
| def.fhirXml = CamelDefinitionYamlStep.readFhirXmlDataFormat(element.fhirXml); |
| } |
| if (element?.barcode !== undefined) { |
| def.barcode = CamelDefinitionYamlStep.readBarcodeDataFormat(element.barcode); |
| } |
| if (element?.avro !== undefined) { |
| def.avro = CamelDefinitionYamlStep.readAvroDataFormat(element.avro); |
| } |
| if (element?.yaml !== undefined) { |
| def.yaml = CamelDefinitionYamlStep.readYAMLDataFormat(element.yaml); |
| } |
| if (element?.fhirJson !== undefined) { |
| def.fhirJson = CamelDefinitionYamlStep.readFhirJsonDataFormat(element.fhirJson); |
| } |
| if (element?.any23 !== undefined) { |
| def.any23 = CamelDefinitionYamlStep.readAny23DataFormat(element.any23); |
| } |
| if (element?.custom !== undefined) { |
| def.custom = CamelDefinitionYamlStep.readCustomDataFormat(element.custom); |
| } |
| if (element?.flatpack !== undefined) { |
| def.flatpack = CamelDefinitionYamlStep.readFlatpackDataFormat(element.flatpack); |
| } |
| if (element?.cbor !== undefined) { |
| def.cbor = CamelDefinitionYamlStep.readCBORDataFormat(element.cbor); |
| } |
| if (element?.crypto !== undefined) { |
| def.crypto = CamelDefinitionYamlStep.readCryptoDataFormat(element.crypto); |
| } |
| if (element?.univocityTsv !== undefined) { |
| def.univocityTsv = CamelDefinitionYamlStep.readUniVocityTsvDataFormat(element.univocityTsv); |
| } |
| if (element?.hl7 !== undefined) { |
| def.hl7 = CamelDefinitionYamlStep.readHL7DataFormat(element.hl7); |
| } |
| if (element?.jsonApi !== undefined) { |
| def.jsonApi = CamelDefinitionYamlStep.readJsonApiDataFormat(element.jsonApi); |
| } |
| if (element?.xmlSecurity !== undefined) { |
| def.xmlSecurity = CamelDefinitionYamlStep.readXMLSecurityDataFormat(element.xmlSecurity); |
| } |
| if (element?.ical !== undefined) { |
| def.ical = CamelDefinitionYamlStep.readIcalDataFormat(element.ical); |
| } |
| if (element?.univocityFixed !== undefined) { |
| def.univocityFixed = CamelDefinitionYamlStep.readUniVocityFixedDataFormat(element.univocityFixed); |
| } |
| if (element?.jacksonXml !== undefined) { |
| def.jacksonXml = CamelDefinitionYamlStep.readJacksonXMLDataFormat(element.jacksonXml); |
| } |
| if (element?.grok !== undefined) { |
| def.grok = CamelDefinitionYamlStep.readGrokDataFormat(element.grok); |
| } |
| if (element?.xstream !== undefined) { |
| def.xstream = CamelDefinitionYamlStep.readXStreamDataFormat(element.xstream); |
| } |
| if (element?.gzipDeflater !== undefined) { |
| def.gzipDeflater = CamelDefinitionYamlStep.readGzipDeflaterDataFormat(element.gzipDeflater); |
| } |
| if (element?.soap !== undefined) { |
| def.soap = CamelDefinitionYamlStep.readSoapDataFormat(element.soap); |
| } |
| |
| return def; |
| } |
| |
| static readFhirJsonDataFormat = (element: any): FhirJsonDataFormat => { |
| |
| const def = element ? new FhirJsonDataFormat({...element}) : new FhirJsonDataFormat(); |
| |
| return def; |
| } |
| |
| static readFhirXmlDataFormat = (element: any): FhirXmlDataFormat => { |
| |
| const def = element ? new FhirXmlDataFormat({...element}) : new FhirXmlDataFormat(); |
| |
| return def; |
| } |
| |
| static readFlatpackDataFormat = (element: any): FlatpackDataFormat => { |
| |
| const def = element ? new FlatpackDataFormat({...element}) : new FlatpackDataFormat(); |
| |
| return def; |
| } |
| |
| static readGrokDataFormat = (element: any): GrokDataFormat => { |
| |
| const def = element ? new GrokDataFormat({...element}) : new GrokDataFormat(); |
| |
| return def; |
| } |
| |
| static readGzipDeflaterDataFormat = (element: any): GzipDeflaterDataFormat => { |
| |
| const def = element ? new GzipDeflaterDataFormat({...element}) : new GzipDeflaterDataFormat(); |
| |
| return def; |
| } |
| |
| static readHL7DataFormat = (element: any): HL7DataFormat => { |
| |
| const def = element ? new HL7DataFormat({...element}) : new HL7DataFormat(); |
| |
| return def; |
| } |
| |
| static readIcalDataFormat = (element: any): IcalDataFormat => { |
| |
| const def = element ? new IcalDataFormat({...element}) : new IcalDataFormat(); |
| |
| return def; |
| } |
| |
| static readJacksonXMLDataFormat = (element: any): JacksonXMLDataFormat => { |
| |
| const def = element ? new JacksonXMLDataFormat({...element}) : new JacksonXMLDataFormat(); |
| |
| return def; |
| } |
| |
| static readJaxbDataFormat = (element: any): JaxbDataFormat => { |
| |
| const def = element ? new JaxbDataFormat({...element}) : new JaxbDataFormat(); |
| |
| return def; |
| } |
| |
| static readJsonApiDataFormat = (element: any): JsonApiDataFormat => { |
| |
| const def = element ? new JsonApiDataFormat({...element}) : new JsonApiDataFormat(); |
| |
| return def; |
| } |
| |
| static readJsonDataFormat = (element: any): JsonDataFormat => { |
| |
| const def = element ? new JsonDataFormat({...element}) : new JsonDataFormat(); |
| |
| return def; |
| } |
| |
| static readLZFDataFormat = (element: any): LZFDataFormat => { |
| |
| const def = element ? new LZFDataFormat({...element}) : new LZFDataFormat(); |
| |
| return def; |
| } |
| |
| static readMimeMultipartDataFormat = (element: any): MimeMultipartDataFormat => { |
| |
| const def = element ? new MimeMultipartDataFormat({...element}) : new MimeMultipartDataFormat(); |
| |
| return def; |
| } |
| |
| static readPGPDataFormat = (element: any): PGPDataFormat => { |
| |
| const def = element ? new PGPDataFormat({...element}) : new PGPDataFormat(); |
| |
| return def; |
| } |
| |
| static readProtobufDataFormat = (element: any): ProtobufDataFormat => { |
| |
| const def = element ? new ProtobufDataFormat({...element}) : new ProtobufDataFormat(); |
| |
| return def; |
| } |
| |
| static readRssDataFormat = (element: any): RssDataFormat => { |
| |
| const def = element ? new RssDataFormat({...element}) : new RssDataFormat(); |
| |
| return def; |
| } |
| |
| static readSoapDataFormat = (element: any): SoapDataFormat => { |
| if (element && typeof element === 'string') element = {contextPath: element}; |
| const def = element ? new SoapDataFormat({...element}) : new SoapDataFormat(); |
| |
| return def; |
| } |
| |
| static readSyslogDataFormat = (element: any): SyslogDataFormat => { |
| |
| const def = element ? new SyslogDataFormat({...element}) : new SyslogDataFormat(); |
| |
| return def; |
| } |
| |
| static readTarFileDataFormat = (element: any): TarFileDataFormat => { |
| |
| const def = element ? new TarFileDataFormat({...element}) : new TarFileDataFormat(); |
| |
| return def; |
| } |
| |
| static readThriftDataFormat = (element: any): ThriftDataFormat => { |
| |
| const def = element ? new ThriftDataFormat({...element}) : new ThriftDataFormat(); |
| |
| return def; |
| } |
| |
| static readTidyMarkupDataFormat = (element: any): TidyMarkupDataFormat => { |
| |
| const def = element ? new TidyMarkupDataFormat({...element}) : new TidyMarkupDataFormat(); |
| |
| return def; |
| } |
| |
| static readUniVocityCsvDataFormat = (element: any): UniVocityCsvDataFormat => { |
| |
| const def = element ? new UniVocityCsvDataFormat({...element}) : new UniVocityCsvDataFormat(); |
| def.univocityHeader = element && element?.univocityHeader ? element?.univocityHeader.map((x:any) => CamelDefinitionYamlStep.readUniVocityHeader(x)) :[]; |
| |
| return def; |
| } |
| |
| static readUniVocityFixedDataFormat = (element: any): UniVocityFixedDataFormat => { |
| |
| const def = element ? new UniVocityFixedDataFormat({...element}) : new UniVocityFixedDataFormat(); |
| def.univocityHeader = element && element?.univocityHeader ? element?.univocityHeader.map((x:any) => CamelDefinitionYamlStep.readUniVocityHeader(x)) :[]; |
| |
| return def; |
| } |
| |
| static readUniVocityHeader = (element: any): UniVocityHeader => { |
| |
| const def = element ? new UniVocityHeader({...element}) : new UniVocityHeader(); |
| |
| return def; |
| } |
| |
| static readUniVocityTsvDataFormat = (element: any): UniVocityTsvDataFormat => { |
| |
| const def = element ? new UniVocityTsvDataFormat({...element}) : new UniVocityTsvDataFormat(); |
| def.univocityHeader = element && element?.univocityHeader ? element?.univocityHeader.map((x:any) => CamelDefinitionYamlStep.readUniVocityHeader(x)) :[]; |
| |
| return def; |
| } |
| |
| static readXMLSecurityDataFormat = (element: any): XMLSecurityDataFormat => { |
| |
| const def = element ? new XMLSecurityDataFormat({...element}) : new XMLSecurityDataFormat(); |
| |
| return def; |
| } |
| |
| static readXStreamDataFormat = (element: any): XStreamDataFormat => { |
| |
| const def = element ? new XStreamDataFormat({...element}) : new XStreamDataFormat(); |
| def.omitFields = element && element?.omitFields ? element?.omitFields.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| def.aliases = element && element?.aliases ? element?.aliases.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| def.implicitCollections = element && element?.implicitCollections ? element?.implicitCollections.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| def.converters = element && element?.converters ? element?.converters.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readYAMLDataFormat = (element: any): YAMLDataFormat => { |
| |
| const def = element ? new YAMLDataFormat({...element}) : new YAMLDataFormat(); |
| def.typeFilter = element && element?.typeFilter ? element?.typeFilter.map((x:any) => CamelDefinitionYamlStep.readYAMLTypeFilterDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readYAMLTypeFilterDefinition = (element: any): YAMLTypeFilterDefinition => { |
| |
| const def = element ? new YAMLTypeFilterDefinition({...element}) : new YAMLTypeFilterDefinition(); |
| |
| return def; |
| } |
| |
| static readZipDeflaterDataFormat = (element: any): ZipDeflaterDataFormat => { |
| |
| const def = element ? new ZipDeflaterDataFormat({...element}) : new ZipDeflaterDataFormat(); |
| |
| return def; |
| } |
| |
| static readZipFileDataFormat = (element: any): ZipFileDataFormat => { |
| |
| const def = element ? new ZipFileDataFormat({...element}) : new ZipFileDataFormat(); |
| |
| return def; |
| } |
| |
| static readDeadLetterChannelDefinition = (element: any): DeadLetterChannelDefinition => { |
| |
| const def = element ? new DeadLetterChannelDefinition({...element}) : new DeadLetterChannelDefinition(); |
| if (element?.redeliveryPolicy !== undefined) { |
| def.redeliveryPolicy = CamelDefinitionYamlStep.readRedeliveryPolicyDefinition(element.redeliveryPolicy); |
| } |
| |
| return def; |
| } |
| |
| static readDefaultErrorHandlerDefinition = (element: any): DefaultErrorHandlerDefinition => { |
| |
| const def = element ? new DefaultErrorHandlerDefinition({...element}) : new DefaultErrorHandlerDefinition(); |
| if (element?.redeliveryPolicy !== undefined) { |
| def.redeliveryPolicy = CamelDefinitionYamlStep.readRedeliveryPolicyDefinition(element.redeliveryPolicy); |
| } |
| |
| return def; |
| } |
| |
| static readErrorHandlerRefDefinition = (element: any): ErrorHandlerRefDefinition => { |
| |
| const def = element ? new ErrorHandlerRefDefinition({...element}) : new ErrorHandlerRefDefinition(); |
| |
| return def; |
| } |
| |
| static readJtaTransactionErrorHandlerDefinition = (element: any): JtaTransactionErrorHandlerDefinition => { |
| |
| const def = element ? new JtaTransactionErrorHandlerDefinition({...element}) : new JtaTransactionErrorHandlerDefinition(); |
| if (element?.redeliveryPolicy !== undefined) { |
| def.redeliveryPolicy = CamelDefinitionYamlStep.readRedeliveryPolicyDefinition(element.redeliveryPolicy); |
| } |
| |
| return def; |
| } |
| |
| static readNoErrorHandlerDefinition = (element: any): NoErrorHandlerDefinition => { |
| |
| const def = element ? new NoErrorHandlerDefinition({...element}) : new NoErrorHandlerDefinition(); |
| |
| return def; |
| } |
| |
| static readSpringTransactionErrorHandlerDefinition = (element: any): SpringTransactionErrorHandlerDefinition => { |
| |
| const def = element ? new SpringTransactionErrorHandlerDefinition({...element}) : new SpringTransactionErrorHandlerDefinition(); |
| if (element?.redeliveryPolicy !== undefined) { |
| def.redeliveryPolicy = CamelDefinitionYamlStep.readRedeliveryPolicyDefinition(element.redeliveryPolicy); |
| } |
| |
| return def; |
| } |
| |
| static readCSimpleExpression = (element: any): CSimpleExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new CSimpleExpression({...element}) : new CSimpleExpression(); |
| |
| return def; |
| } |
| |
| static readConstantExpression = (element: any): ConstantExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new ConstantExpression({...element}) : new ConstantExpression(); |
| |
| return def; |
| } |
| |
| static readDatasonnetExpression = (element: any): DatasonnetExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new DatasonnetExpression({...element}) : new DatasonnetExpression(); |
| |
| return def; |
| } |
| |
| static readExchangePropertyExpression = (element: any): ExchangePropertyExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new ExchangePropertyExpression({...element}) : new ExchangePropertyExpression(); |
| |
| return def; |
| } |
| |
| static readExpressionDefinition = (element: any): ExpressionDefinition => { |
| |
| const def = element ? new ExpressionDefinition({...element}) : new ExpressionDefinition(); |
| if (element?.ognl !== undefined) { |
| def.ognl = CamelDefinitionYamlStep.readOgnlExpression(element.ognl); |
| } |
| if (element?.constant !== undefined) { |
| def.constant = CamelDefinitionYamlStep.readConstantExpression(element.constant); |
| } |
| if (element?.mvel !== undefined) { |
| def.mvel = CamelDefinitionYamlStep.readMvelExpression(element.mvel); |
| } |
| if (element?.method !== undefined) { |
| def.method = CamelDefinitionYamlStep.readMethodCallExpression(element.method); |
| } |
| if (element?.xquery !== undefined) { |
| def.xquery = CamelDefinitionYamlStep.readXQueryExpression(element.xquery); |
| } |
| if (element?.datasonnet !== undefined) { |
| def.datasonnet = CamelDefinitionYamlStep.readDatasonnetExpression(element.datasonnet); |
| } |
| if (element?.jq !== undefined) { |
| def.jq = CamelDefinitionYamlStep.readJqExpression(element.jq); |
| } |
| if (element?.language !== undefined) { |
| def.language = CamelDefinitionYamlStep.readLanguageExpression(element.language); |
| } |
| if (element?.simple !== undefined) { |
| def.simple = CamelDefinitionYamlStep.readSimpleExpression(element.simple); |
| } |
| if (element?.hl7terser !== undefined) { |
| def.hl7terser = CamelDefinitionYamlStep.readHl7TerserExpression(element.hl7terser); |
| } |
| if (element?.tokenize !== undefined) { |
| def.tokenize = CamelDefinitionYamlStep.readTokenizerExpression(element.tokenize); |
| } |
| if (element?.spel !== undefined) { |
| def.spel = CamelDefinitionYamlStep.readSpELExpression(element.spel); |
| } |
| if (element?.ref !== undefined) { |
| def.ref = CamelDefinitionYamlStep.readRefExpression(element.ref); |
| } |
| if (element?.xpath !== undefined) { |
| def.xpath = CamelDefinitionYamlStep.readXPathExpression(element.xpath); |
| } |
| if (element?.groovy !== undefined) { |
| def.groovy = CamelDefinitionYamlStep.readGroovyExpression(element.groovy); |
| } |
| if (element?.csimple !== undefined) { |
| def.csimple = CamelDefinitionYamlStep.readCSimpleExpression(element.csimple); |
| } |
| if (element?.exchangeProperty !== undefined) { |
| def.exchangeProperty = CamelDefinitionYamlStep.readExchangePropertyExpression(element.exchangeProperty); |
| } |
| if (element?.jsonpath !== undefined) { |
| def.jsonpath = CamelDefinitionYamlStep.readJsonPathExpression(element.jsonpath); |
| } |
| if (element?.header !== undefined) { |
| def.header = CamelDefinitionYamlStep.readHeaderExpression(element.header); |
| } |
| if (element?.joor !== undefined) { |
| def.joor = CamelDefinitionYamlStep.readJoorExpression(element.joor); |
| } |
| if (element?.xtokenize !== undefined) { |
| def.xtokenize = CamelDefinitionYamlStep.readXMLTokenizerExpression(element.xtokenize); |
| } |
| |
| return def; |
| } |
| |
| static readGroovyExpression = (element: any): GroovyExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new GroovyExpression({...element}) : new GroovyExpression(); |
| |
| return def; |
| } |
| |
| static readHeaderExpression = (element: any): HeaderExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new HeaderExpression({...element}) : new HeaderExpression(); |
| |
| return def; |
| } |
| |
| static readHl7TerserExpression = (element: any): Hl7TerserExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new Hl7TerserExpression({...element}) : new Hl7TerserExpression(); |
| |
| return def; |
| } |
| |
| static readJoorExpression = (element: any): JoorExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new JoorExpression({...element}) : new JoorExpression(); |
| |
| return def; |
| } |
| |
| static readJqExpression = (element: any): JqExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new JqExpression({...element}) : new JqExpression(); |
| |
| return def; |
| } |
| |
| static readJsonPathExpression = (element: any): JsonPathExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new JsonPathExpression({...element}) : new JsonPathExpression(); |
| |
| return def; |
| } |
| |
| static readLanguageExpression = (element: any): LanguageExpression => { |
| |
| const def = element ? new LanguageExpression({...element}) : new LanguageExpression(); |
| |
| return def; |
| } |
| |
| static readMethodCallExpression = (element: any): MethodCallExpression => { |
| |
| const def = element ? new MethodCallExpression({...element}) : new MethodCallExpression(); |
| |
| return def; |
| } |
| |
| static readMvelExpression = (element: any): MvelExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new MvelExpression({...element}) : new MvelExpression(); |
| |
| return def; |
| } |
| |
| static readOgnlExpression = (element: any): OgnlExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new OgnlExpression({...element}) : new OgnlExpression(); |
| |
| return def; |
| } |
| |
| static readRefExpression = (element: any): RefExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new RefExpression({...element}) : new RefExpression(); |
| |
| return def; |
| } |
| |
| static readSimpleExpression = (element: any): SimpleExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new SimpleExpression({...element}) : new SimpleExpression(); |
| |
| return def; |
| } |
| |
| static readSpELExpression = (element: any): SpELExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new SpELExpression({...element}) : new SpELExpression(); |
| |
| return def; |
| } |
| |
| static readTokenizerExpression = (element: any): TokenizerExpression => { |
| if (element && typeof element === 'string') element = {token: element}; |
| const def = element ? new TokenizerExpression({...element}) : new TokenizerExpression(); |
| |
| return def; |
| } |
| |
| static readXMLTokenizerExpression = (element: any): XMLTokenizerExpression => { |
| |
| const def = element ? new XMLTokenizerExpression({...element}) : new XMLTokenizerExpression(); |
| def.namespace = element && element?.namespace ? element?.namespace.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readXPathExpression = (element: any): XPathExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new XPathExpression({...element}) : new XPathExpression(); |
| def.namespace = element && element?.namespace ? element?.namespace.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readXQueryExpression = (element: any): XQueryExpression => { |
| if (element && typeof element === 'string') element = {expression: element}; |
| const def = element ? new XQueryExpression({...element}) : new XQueryExpression(); |
| def.namespace = element && element?.namespace ? element?.namespace.map((x:any) => CamelDefinitionYamlStep.readPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readCustomLoadBalancerDefinition = (element: any): CustomLoadBalancerDefinition => { |
| if (element && typeof element === 'string') element = {ref: element}; |
| const def = element ? new CustomLoadBalancerDefinition({...element}) : new CustomLoadBalancerDefinition(); |
| |
| return def; |
| } |
| |
| static readFailoverLoadBalancerDefinition = (element: any): FailoverLoadBalancerDefinition => { |
| |
| const def = element ? new FailoverLoadBalancerDefinition({...element}) : new FailoverLoadBalancerDefinition(); |
| |
| return def; |
| } |
| |
| static readRandomLoadBalancerDefinition = (element: any): RandomLoadBalancerDefinition => { |
| |
| const def = element ? new RandomLoadBalancerDefinition({...element}) : new RandomLoadBalancerDefinition(); |
| |
| return def; |
| } |
| |
| static readRoundRobinLoadBalancerDefinition = (element: any): RoundRobinLoadBalancerDefinition => { |
| |
| const def = element ? new RoundRobinLoadBalancerDefinition({...element}) : new RoundRobinLoadBalancerDefinition(); |
| |
| return def; |
| } |
| |
| static readStickyLoadBalancerDefinition = (element: any): StickyLoadBalancerDefinition => { |
| |
| const def = element ? new StickyLoadBalancerDefinition({...element}) : new StickyLoadBalancerDefinition(); |
| if (element?.correlationExpression !== undefined) { |
| def.correlationExpression = CamelDefinitionYamlStep.readExpressionSubElementDefinition(element.correlationExpression); |
| } |
| |
| return def; |
| } |
| |
| static readTopicLoadBalancerDefinition = (element: any): TopicLoadBalancerDefinition => { |
| |
| const def = element ? new TopicLoadBalancerDefinition({...element}) : new TopicLoadBalancerDefinition(); |
| |
| return def; |
| } |
| |
| static readWeightedLoadBalancerDefinition = (element: any): WeightedLoadBalancerDefinition => { |
| |
| const def = element ? new WeightedLoadBalancerDefinition({...element}) : new WeightedLoadBalancerDefinition(); |
| |
| return def; |
| } |
| |
| static readApiKeyDefinition = (element: any): ApiKeyDefinition => { |
| |
| const def = element ? new ApiKeyDefinition({...element}) : new ApiKeyDefinition(); |
| |
| return def; |
| } |
| |
| static readBasicAuthDefinition = (element: any): BasicAuthDefinition => { |
| |
| const def = element ? new BasicAuthDefinition({...element}) : new BasicAuthDefinition(); |
| |
| return def; |
| } |
| |
| static readBearerTokenDefinition = (element: any): BearerTokenDefinition => { |
| |
| const def = element ? new BearerTokenDefinition({...element}) : new BearerTokenDefinition(); |
| |
| return def; |
| } |
| |
| static readDeleteDefinition = (element: any): DeleteDefinition => { |
| |
| const def = element ? new DeleteDefinition({...element}) : new DeleteDefinition(); |
| def.security = element && element?.security ? element?.security.map((x:any) => CamelDefinitionYamlStep.readSecurityDefinition(x)) :[]; |
| def.param = element && element?.param ? element?.param.map((x:any) => CamelDefinitionYamlStep.readParamDefinition(x)) :[]; |
| def.responseMessage = element && element?.responseMessage ? element?.responseMessage.map((x:any) => CamelDefinitionYamlStep.readResponseMessageDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readGetDefinition = (element: any): GetDefinition => { |
| |
| const def = element ? new GetDefinition({...element}) : new GetDefinition(); |
| def.security = element && element?.security ? element?.security.map((x:any) => CamelDefinitionYamlStep.readSecurityDefinition(x)) :[]; |
| def.param = element && element?.param ? element?.param.map((x:any) => CamelDefinitionYamlStep.readParamDefinition(x)) :[]; |
| def.responseMessage = element && element?.responseMessage ? element?.responseMessage.map((x:any) => CamelDefinitionYamlStep.readResponseMessageDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readHeadDefinition = (element: any): HeadDefinition => { |
| |
| const def = element ? new HeadDefinition({...element}) : new HeadDefinition(); |
| def.security = element && element?.security ? element?.security.map((x:any) => CamelDefinitionYamlStep.readSecurityDefinition(x)) :[]; |
| def.param = element && element?.param ? element?.param.map((x:any) => CamelDefinitionYamlStep.readParamDefinition(x)) :[]; |
| def.responseMessage = element && element?.responseMessage ? element?.responseMessage.map((x:any) => CamelDefinitionYamlStep.readResponseMessageDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readMutualTLSDefinition = (element: any): MutualTLSDefinition => { |
| |
| const def = element ? new MutualTLSDefinition({...element}) : new MutualTLSDefinition(); |
| |
| return def; |
| } |
| |
| static readOAuth2Definition = (element: any): OAuth2Definition => { |
| |
| const def = element ? new OAuth2Definition({...element}) : new OAuth2Definition(); |
| def.scopes = element && element?.scopes ? element?.scopes.map((x:any) => CamelDefinitionYamlStep.readRestPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readOpenIdConnectDefinition = (element: any): OpenIdConnectDefinition => { |
| |
| const def = element ? new OpenIdConnectDefinition({...element}) : new OpenIdConnectDefinition(); |
| |
| return def; |
| } |
| |
| static readParamDefinition = (element: any): ParamDefinition => { |
| |
| const def = element ? new ParamDefinition({...element}) : new ParamDefinition(); |
| def.examples = element && element?.examples ? element?.examples.map((x:any) => CamelDefinitionYamlStep.readRestPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readPatchDefinition = (element: any): PatchDefinition => { |
| |
| const def = element ? new PatchDefinition({...element}) : new PatchDefinition(); |
| def.security = element && element?.security ? element?.security.map((x:any) => CamelDefinitionYamlStep.readSecurityDefinition(x)) :[]; |
| def.param = element && element?.param ? element?.param.map((x:any) => CamelDefinitionYamlStep.readParamDefinition(x)) :[]; |
| def.responseMessage = element && element?.responseMessage ? element?.responseMessage.map((x:any) => CamelDefinitionYamlStep.readResponseMessageDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readPostDefinition = (element: any): PostDefinition => { |
| |
| const def = element ? new PostDefinition({...element}) : new PostDefinition(); |
| def.security = element && element?.security ? element?.security.map((x:any) => CamelDefinitionYamlStep.readSecurityDefinition(x)) :[]; |
| def.param = element && element?.param ? element?.param.map((x:any) => CamelDefinitionYamlStep.readParamDefinition(x)) :[]; |
| def.responseMessage = element && element?.responseMessage ? element?.responseMessage.map((x:any) => CamelDefinitionYamlStep.readResponseMessageDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readPutDefinition = (element: any): PutDefinition => { |
| |
| const def = element ? new PutDefinition({...element}) : new PutDefinition(); |
| def.security = element && element?.security ? element?.security.map((x:any) => CamelDefinitionYamlStep.readSecurityDefinition(x)) :[]; |
| def.param = element && element?.param ? element?.param.map((x:any) => CamelDefinitionYamlStep.readParamDefinition(x)) :[]; |
| def.responseMessage = element && element?.responseMessage ? element?.responseMessage.map((x:any) => CamelDefinitionYamlStep.readResponseMessageDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readResponseHeaderDefinition = (element: any): ResponseHeaderDefinition => { |
| |
| const def = element ? new ResponseHeaderDefinition({...element}) : new ResponseHeaderDefinition(); |
| |
| return def; |
| } |
| |
| static readResponseMessageDefinition = (element: any): ResponseMessageDefinition => { |
| |
| const def = element ? new ResponseMessageDefinition({...element}) : new ResponseMessageDefinition(); |
| def.examples = element && element?.examples ? element?.examples.map((x:any) => CamelDefinitionYamlStep.readRestPropertyDefinition(x)) :[]; |
| def.header = element && element?.header ? element?.header.map((x:any) => CamelDefinitionYamlStep.readResponseHeaderDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readRestBindingDefinition = (element: any): RestBindingDefinition => { |
| |
| const def = element ? new RestBindingDefinition({...element}) : new RestBindingDefinition(); |
| |
| return def; |
| } |
| |
| static readRestConfigurationDefinition = (element: any): RestConfigurationDefinition => { |
| |
| const def = element ? new RestConfigurationDefinition({...element}) : new RestConfigurationDefinition(); |
| def.corsHeaders = element && element?.corsHeaders ? element?.corsHeaders.map((x:any) => CamelDefinitionYamlStep.readRestPropertyDefinition(x)) :[]; |
| def.dataFormatProperty = element && element?.dataFormatProperty ? element?.dataFormatProperty.map((x:any) => CamelDefinitionYamlStep.readRestPropertyDefinition(x)) :[]; |
| def.consumerProperty = element && element?.consumerProperty ? element?.consumerProperty.map((x:any) => CamelDefinitionYamlStep.readRestPropertyDefinition(x)) :[]; |
| def.apiProperty = element && element?.apiProperty ? element?.apiProperty.map((x:any) => CamelDefinitionYamlStep.readRestPropertyDefinition(x)) :[]; |
| def.endpointProperty = element && element?.endpointProperty ? element?.endpointProperty.map((x:any) => CamelDefinitionYamlStep.readRestPropertyDefinition(x)) :[]; |
| def.componentProperty = element && element?.componentProperty ? element?.componentProperty.map((x:any) => CamelDefinitionYamlStep.readRestPropertyDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readRestDefinition = (element: any): RestDefinition => { |
| |
| const def = element ? new RestDefinition({...element}) : new RestDefinition(); |
| def.head = element && element?.head ? element?.head.map((x:any) => CamelDefinitionYamlStep.readHeadDefinition(x)) :[]; |
| def.patch = element && element?.patch ? element?.patch.map((x:any) => CamelDefinitionYamlStep.readPatchDefinition(x)) :[]; |
| def.post = element && element?.post ? element?.post.map((x:any) => CamelDefinitionYamlStep.readPostDefinition(x)) :[]; |
| def.get = element && element?.get ? element?.get.map((x:any) => CamelDefinitionYamlStep.readGetDefinition(x)) :[]; |
| def.securityRequirements = element && element?.securityRequirements ? element?.securityRequirements.map((x:any) => CamelDefinitionYamlStep.readSecurityDefinition(x)) :[]; |
| def.delete = element && element?.delete ? element?.delete.map((x:any) => CamelDefinitionYamlStep.readDeleteDefinition(x)) :[]; |
| if (element?.securityDefinitions !== undefined) { |
| def.securityDefinitions = CamelDefinitionYamlStep.readRestSecuritiesDefinition(element.securityDefinitions); |
| } |
| def.put = element && element?.put ? element?.put.map((x:any) => CamelDefinitionYamlStep.readPutDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readRestPropertyDefinition = (element: any): RestPropertyDefinition => { |
| |
| const def = element ? new RestPropertyDefinition({...element}) : new RestPropertyDefinition(); |
| |
| return def; |
| } |
| |
| static readRestSecuritiesDefinition = (element: any): RestSecuritiesDefinition => { |
| |
| const def = element ? new RestSecuritiesDefinition({...element}) : new RestSecuritiesDefinition(); |
| if (element?.openIdConnect !== undefined) { |
| def.openIdConnect = CamelDefinitionYamlStep.readOpenIdConnectDefinition(element.openIdConnect); |
| } |
| if (element?.apiKey !== undefined) { |
| def.apiKey = CamelDefinitionYamlStep.readApiKeyDefinition(element.apiKey); |
| } |
| if (element?.basicAuth !== undefined) { |
| def.basicAuth = CamelDefinitionYamlStep.readBasicAuthDefinition(element.basicAuth); |
| } |
| if (element?.mutualTls !== undefined) { |
| def.mutualTls = CamelDefinitionYamlStep.readMutualTLSDefinition(element.mutualTls); |
| } |
| if (element?.bearer !== undefined) { |
| def.bearer = CamelDefinitionYamlStep.readBearerTokenDefinition(element.bearer); |
| } |
| if (element?.oauth2 !== undefined) { |
| def.oauth2 = CamelDefinitionYamlStep.readOAuth2Definition(element.oauth2); |
| } |
| |
| return def; |
| } |
| |
| static readRestsDefinition = (element: any): RestsDefinition => { |
| |
| const def = element ? new RestsDefinition({...element}) : new RestsDefinition(); |
| def.rest = element && element?.rest ? element?.rest.map((x:any) => CamelDefinitionYamlStep.readRestDefinition(x)) :[]; |
| |
| return def; |
| } |
| |
| static readSecurityDefinition = (element: any): SecurityDefinition => { |
| |
| const def = element ? new SecurityDefinition({...element}) : new SecurityDefinition(); |
| |
| return def; |
| } |
| |
| static readCustomTransformerDefinition = (element: any): CustomTransformerDefinition => { |
| |
| const def = element ? new CustomTransformerDefinition({...element}) : new CustomTransformerDefinition(); |
| |
| return def; |
| } |
| |
| static readDataFormatTransformerDefinition = (element: any): DataFormatTransformerDefinition => { |
| |
| const def = element ? new DataFormatTransformerDefinition({...element}) : new DataFormatTransformerDefinition(); |
| if (element?.univocityCsv !== undefined) { |
| def.univocityCsv = CamelDefinitionYamlStep.readUniVocityCsvDataFormat(element.univocityCsv); |
| } |
| if (element?.protobuf !== undefined) { |
| def.protobuf = CamelDefinitionYamlStep.readProtobufDataFormat(element.protobuf); |
| } |
| if (element?.tarFile !== undefined) { |
| def.tarFile = CamelDefinitionYamlStep.readTarFileDataFormat(element.tarFile); |
| } |
| if (element?.tidyMarkup !== undefined) { |
| def.tidyMarkup = CamelDefinitionYamlStep.readTidyMarkupDataFormat(element.tidyMarkup); |
| } |
| if (element?.csv !== undefined) { |
| def.csv = CamelDefinitionYamlStep.readCsvDataFormat(element.csv); |
| } |
| if (element?.base64 !== undefined) { |
| def.base64 = CamelDefinitionYamlStep.readBase64DataFormat(element.base64); |
| } |
| if (element?.zipDeflater !== undefined) { |
| def.zipDeflater = CamelDefinitionYamlStep.readZipDeflaterDataFormat(element.zipDeflater); |
| } |
| if (element?.bindy !== undefined) { |
| def.bindy = CamelDefinitionYamlStep.readBindyDataFormat(element.bindy); |
| } |
| if (element?.syslog !== undefined) { |
| def.syslog = CamelDefinitionYamlStep.readSyslogDataFormat(element.syslog); |
| } |
| if (element?.zipFile !== undefined) { |
| def.zipFile = CamelDefinitionYamlStep.readZipFileDataFormat(element.zipFile); |
| } |
| if (element?.jaxb !== undefined) { |
| def.jaxb = CamelDefinitionYamlStep.readJaxbDataFormat(element.jaxb); |
| } |
| if (element?.rss !== undefined) { |
| def.rss = CamelDefinitionYamlStep.readRssDataFormat(element.rss); |
| } |
| if (element?.mimeMultipart !== undefined) { |
| def.mimeMultipart = CamelDefinitionYamlStep.readMimeMultipartDataFormat(element.mimeMultipart); |
| } |
| if (element?.asn1 !== undefined) { |
| def.asn1 = CamelDefinitionYamlStep.readASN1DataFormat(element.asn1); |
| } |
| if (element?.pgp !== undefined) { |
| def.pgp = CamelDefinitionYamlStep.readPGPDataFormat(element.pgp); |
| } |
| if (element?.thrift !== undefined) { |
| def.thrift = CamelDefinitionYamlStep.readThriftDataFormat(element.thrift); |
| } |
| if (element?.json !== undefined) { |
| def.json = CamelDefinitionYamlStep.readJsonDataFormat(element.json); |
| } |
| if (element?.lzf !== undefined) { |
| def.lzf = CamelDefinitionYamlStep.readLZFDataFormat(element.lzf); |
| } |
| if (element?.fhirXml !== undefined) { |
| def.fhirXml = CamelDefinitionYamlStep.readFhirXmlDataFormat(element.fhirXml); |
| } |
| if (element?.barcode !== undefined) { |
| def.barcode = CamelDefinitionYamlStep.readBarcodeDataFormat(element.barcode); |
| } |
| if (element?.avro !== undefined) { |
| def.avro = CamelDefinitionYamlStep.readAvroDataFormat(element.avro); |
| } |
| if (element?.yaml !== undefined) { |
| def.yaml = CamelDefinitionYamlStep.readYAMLDataFormat(element.yaml); |
| } |
| if (element?.fhirJson !== undefined) { |
| def.fhirJson = CamelDefinitionYamlStep.readFhirJsonDataFormat(element.fhirJson); |
| } |
| if (element?.any23 !== undefined) { |
| def.any23 = CamelDefinitionYamlStep.readAny23DataFormat(element.any23); |
| } |
| if (element?.custom !== undefined) { |
| def.custom = CamelDefinitionYamlStep.readCustomDataFormat(element.custom); |
| } |
| if (element?.flatpack !== undefined) { |
| def.flatpack = CamelDefinitionYamlStep.readFlatpackDataFormat(element.flatpack); |
| } |
| if (element?.cbor !== undefined) { |
| def.cbor = CamelDefinitionYamlStep.readCBORDataFormat(element.cbor); |
| } |
| if (element?.crypto !== undefined) { |
| def.crypto = CamelDefinitionYamlStep.readCryptoDataFormat(element.crypto); |
| } |
| if (element?.univocityTsv !== undefined) { |
| def.univocityTsv = CamelDefinitionYamlStep.readUniVocityTsvDataFormat(element.univocityTsv); |
| } |
| if (element?.hl7 !== undefined) { |
| def.hl7 = CamelDefinitionYamlStep.readHL7DataFormat(element.hl7); |
| } |
| if (element?.jsonApi !== undefined) { |
| def.jsonApi = CamelDefinitionYamlStep.readJsonApiDataFormat(element.jsonApi); |
| } |
| if (element?.xmlSecurity !== undefined) { |
| def.xmlSecurity = CamelDefinitionYamlStep.readXMLSecurityDataFormat(element.xmlSecurity); |
| } |
| if (element?.ical !== undefined) { |
| def.ical = CamelDefinitionYamlStep.readIcalDataFormat(element.ical); |
| } |
| if (element?.univocityFixed !== undefined) { |
| def.univocityFixed = CamelDefinitionYamlStep.readUniVocityFixedDataFormat(element.univocityFixed); |
| } |
| if (element?.jacksonXml !== undefined) { |
| def.jacksonXml = CamelDefinitionYamlStep.readJacksonXMLDataFormat(element.jacksonXml); |
| } |
| if (element?.grok !== undefined) { |
| def.grok = CamelDefinitionYamlStep.readGrokDataFormat(element.grok); |
| } |
| if (element?.xstream !== undefined) { |
| def.xstream = CamelDefinitionYamlStep.readXStreamDataFormat(element.xstream); |
| } |
| if (element?.gzipDeflater !== undefined) { |
| def.gzipDeflater = CamelDefinitionYamlStep.readGzipDeflaterDataFormat(element.gzipDeflater); |
| } |
| if (element?.soap !== undefined) { |
| def.soap = CamelDefinitionYamlStep.readSoapDataFormat(element.soap); |
| } |
| |
| return def; |
| } |
| |
| static readEndpointTransformerDefinition = (element: any): EndpointTransformerDefinition => { |
| |
| const def = element ? new EndpointTransformerDefinition({...element}) : new EndpointTransformerDefinition(); |
| |
| return def; |
| } |
| |
| static readTransformersDefinition = (element: any): TransformersDefinition => { |
| |
| const def = element ? new TransformersDefinition({...element}) : new TransformersDefinition(); |
| if (element?.endpointTransformer !== undefined) { |
| def.endpointTransformer = CamelDefinitionYamlStep.readEndpointTransformerDefinition(element.endpointTransformer); |
| } |
| if (element?.customTransformer !== undefined) { |
| def.customTransformer = CamelDefinitionYamlStep.readCustomTransformerDefinition(element.customTransformer); |
| } |
| if (element?.dataFormatTransformer !== undefined) { |
| def.dataFormatTransformer = CamelDefinitionYamlStep.readDataFormatTransformerDefinition(element.dataFormatTransformer); |
| } |
| |
| return def; |
| } |
| |
| static readCustomValidatorDefinition = (element: any): CustomValidatorDefinition => { |
| |
| const def = element ? new CustomValidatorDefinition({...element}) : new CustomValidatorDefinition(); |
| |
| return def; |
| } |
| |
| static readEndpointValidatorDefinition = (element: any): EndpointValidatorDefinition => { |
| |
| const def = element ? new EndpointValidatorDefinition({...element}) : new EndpointValidatorDefinition(); |
| |
| return def; |
| } |
| |
| static readPredicateValidatorDefinition = (element: any): PredicateValidatorDefinition => { |
| |
| const def = element ? new PredicateValidatorDefinition({...element}) : new PredicateValidatorDefinition(); |
| if (element?.expression !== undefined) { |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(element.expression); |
| } else { |
| const languageName: string | undefined = Object.keys(element).filter(key => CamelMetadataApi.hasLanguage(key))[0] || undefined; |
| if (languageName){ |
| const exp:any = {}; |
| exp[languageName] = element[languageName] |
| def.expression = CamelDefinitionYamlStep.readExpressionDefinition(exp); |
| delete (def as any)[languageName]; |
| } |
| } |
| |
| return def; |
| } |
| |
| static readValidatorsDefinition = (element: any): ValidatorsDefinition => { |
| |
| const def = element ? new ValidatorsDefinition({...element}) : new ValidatorsDefinition(); |
| if (element?.predicateValidator !== undefined) { |
| def.predicateValidator = CamelDefinitionYamlStep.readPredicateValidatorDefinition(element.predicateValidator); |
| } |
| if (element?.endpointValidator !== undefined) { |
| def.endpointValidator = CamelDefinitionYamlStep.readEndpointValidatorDefinition(element.endpointValidator); |
| } |
| if (element?.customValidator !== undefined) { |
| def.customValidator = CamelDefinitionYamlStep.readCustomValidatorDefinition(element.customValidator); |
| } |
| |
| return def; |
| } |
| |
| static readStep = (body: any, clone: boolean = false): CamelElement => { |
| const name = Object.getOwnPropertyNames(body)[0]; |
| const newBody = CamelUtil.camelizeBody(name, body[name], clone); |
| switch (name) { |
| case 'setProperty': return CamelDefinitionYamlStep.readSetPropertyDefinition(newBody); |
| case 'to': return CamelDefinitionYamlStep.readToDefinition(newBody); |
| case 'doCatch': return CamelDefinitionYamlStep.readCatchDefinition(newBody); |
| case 'inOut': return CamelDefinitionYamlStep.readInOutDefinition(newBody); |
| case 'onFallback': return CamelDefinitionYamlStep.readOnFallbackDefinition(newBody); |
| case 'loadBalance': return CamelDefinitionYamlStep.readLoadBalanceDefinition(newBody); |
| case 'process': return CamelDefinitionYamlStep.readProcessDefinition(newBody); |
| case 'bean': return CamelDefinitionYamlStep.readBeanDefinition(newBody); |
| case 'transacted': return CamelDefinitionYamlStep.readTransactedDefinition(newBody); |
| case 'pollEnrich': return CamelDefinitionYamlStep.readPollEnrichDefinition(newBody); |
| case 'filter': return CamelDefinitionYamlStep.readFilterDefinition(newBody); |
| case 'pausable': return CamelDefinitionYamlStep.readPausableDefinition(newBody); |
| case 'setBody': return CamelDefinitionYamlStep.readSetBodyDefinition(newBody); |
| case 'claimCheck': return CamelDefinitionYamlStep.readClaimCheckDefinition(newBody); |
| case 'step': return CamelDefinitionYamlStep.readStepDefinition(newBody); |
| case 'aggregate': return CamelDefinitionYamlStep.readAggregateDefinition(newBody); |
| case 'when': return CamelDefinitionYamlStep.readWhenDefinition(newBody); |
| case 'loop': return CamelDefinitionYamlStep.readLoopDefinition(newBody); |
| case 'stop': return CamelDefinitionYamlStep.readStopDefinition(newBody); |
| case 'resumable': return CamelDefinitionYamlStep.readResumableDefinition(newBody); |
| case 'removeProperty': return CamelDefinitionYamlStep.readRemovePropertyDefinition(newBody); |
| case 'split': return CamelDefinitionYamlStep.readSplitDefinition(newBody); |
| case 'multicast': return CamelDefinitionYamlStep.readMulticastDefinition(newBody); |
| case 'otherwise': return CamelDefinitionYamlStep.readOtherwiseDefinition(newBody); |
| case 'removeProperties': return CamelDefinitionYamlStep.readRemovePropertiesDefinition(newBody); |
| case 'saga': return CamelDefinitionYamlStep.readSagaDefinition(newBody); |
| case 'removeHeaders': return CamelDefinitionYamlStep.readRemoveHeadersDefinition(newBody); |
| case 'setExchangePattern': return CamelDefinitionYamlStep.readSetExchangePatternDefinition(newBody); |
| case 'intercept': return CamelDefinitionYamlStep.readInterceptDefinition(newBody); |
| case 'transform': return CamelDefinitionYamlStep.readTransformDefinition(newBody); |
| case 'routingSlip': return CamelDefinitionYamlStep.readRoutingSlipDefinition(newBody); |
| case 'doTry': return CamelDefinitionYamlStep.readTryDefinition(newBody); |
| case 'delay': return CamelDefinitionYamlStep.readDelayDefinition(newBody); |
| case 'script': return CamelDefinitionYamlStep.readScriptDefinition(newBody); |
| case 'inOnly': return CamelDefinitionYamlStep.readInOnlyDefinition(newBody); |
| case 'enrich': return CamelDefinitionYamlStep.readEnrichDefinition(newBody); |
| case 'onCompletion': return CamelDefinitionYamlStep.readOnCompletionDefinition(newBody); |
| case 'wireTap': return CamelDefinitionYamlStep.readWireTapDefinition(newBody); |
| case 'kamelet': return CamelDefinitionYamlStep.readKameletDefinition(newBody); |
| case 'interceptFrom': return CamelDefinitionYamlStep.readInterceptFromDefinition(newBody); |
| case 'doFinally': return CamelDefinitionYamlStep.readFinallyDefinition(newBody); |
| case 'idempotentConsumer': return CamelDefinitionYamlStep.readIdempotentConsumerDefinition(newBody); |
| case 'removeHeader': return CamelDefinitionYamlStep.readRemoveHeaderDefinition(newBody); |
| case 'circuitBreaker': return CamelDefinitionYamlStep.readCircuitBreakerDefinition(newBody); |
| case 'rollback': return CamelDefinitionYamlStep.readRollbackDefinition(newBody); |
| case 'dynamicRouter': return CamelDefinitionYamlStep.readDynamicRouterDefinition(newBody); |
| case 'resequence': return CamelDefinitionYamlStep.readResequenceDefinition(newBody); |
| case 'log': return CamelDefinitionYamlStep.readLogDefinition(newBody); |
| case 'throttle': return CamelDefinitionYamlStep.readThrottleDefinition(newBody); |
| case 'recipientList': return CamelDefinitionYamlStep.readRecipientListDefinition(newBody); |
| case 'marshal': return CamelDefinitionYamlStep.readMarshalDefinition(newBody); |
| case 'policy': return CamelDefinitionYamlStep.readPolicyDefinition(newBody); |
| case 'serviceCall': return CamelDefinitionYamlStep.readServiceCallDefinition(newBody); |
| case 'unmarshal': return CamelDefinitionYamlStep.readUnmarshalDefinition(newBody); |
| case 'threads': return CamelDefinitionYamlStep.readThreadsDefinition(newBody); |
| case 'toD': return CamelDefinitionYamlStep.readToDynamicDefinition(newBody); |
| case 'convertBodyTo': return CamelDefinitionYamlStep.readConvertBodyDefinition(newBody); |
| case 'pipeline': return CamelDefinitionYamlStep.readPipelineDefinition(newBody); |
| case 'throwException': return CamelDefinitionYamlStep.readThrowExceptionDefinition(newBody); |
| case 'validate': return CamelDefinitionYamlStep.readValidateDefinition(newBody); |
| case 'interceptSendToEndpoint': return CamelDefinitionYamlStep.readInterceptSendToEndpointDefinition(newBody); |
| case 'choice': return CamelDefinitionYamlStep.readChoiceDefinition(newBody); |
| case 'whenSkipSendToEndpoint': return CamelDefinitionYamlStep.readWhenSkipSendToEndpointDefinition(newBody); |
| case 'sample': return CamelDefinitionYamlStep.readSamplingDefinition(newBody); |
| case 'setHeader': return CamelDefinitionYamlStep.readSetHeaderDefinition(newBody); |
| case 'sort': return CamelDefinitionYamlStep.readSortDefinition(newBody); |
| case 'toD': return CamelDefinitionYamlStep.readToDynamicDefinition(newBody); |
| default: return new CamelElement(''); |
| } |
| } |
| |
| static readSteps = (elements: any[] | undefined): CamelElement[] => { |
| const result: CamelElement[] = [] |
| if (elements !== undefined){ |
| elements.forEach(e => { |
| result.push(CamelDefinitionYamlStep.readStep(e)); |
| }) |
| } |
| return result |
| } |
| } |