1 <routes xmlns="http://camel.apache.org/schema/spring">
2 <route id="deploy-loop">
3 <from uri="direct:deploy-loop" />
6 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getUniqueBlueprint()} == true
8 <to uri="direct:deploy-loop-single-blueprint" />
11 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getUniqueBlueprint()} == false
13 <to uri="direct:deploy-loop-multi-blueprint" />
17 <route id="deploy-loop-multi-blueprint">
18 <from uri="direct:deploy-loop-multi-blueprint" />
20 <log loggingLevel="INFO"
21 message="Deploying the blueprints for loop: ${exchangeProperty[loopObject].getName()}" />
23 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Deploying the loop with multiple blueprints')" />
25 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
27 <setProperty propertyName="microServicePolicy">
28 <simple>${body}</simple>
32 message="Processing Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
33 <setProperty propertyName="raiseHttpExceptionFlag">
34 <simple resultType="java.lang.Boolean">false</simple>
37 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
38 method="getDeployPayload(${exchangeProperty[loopObject]},${exchangeProperty[microServicePolicy]})" />
40 <setProperty propertyName="dcaeDeploymentId">
41 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
42 method="generateDeploymentId()" />
44 <setHeader headerName="CamelHttpMethod">
45 <constant>PUT</constant>
47 <setHeader headerName="Content-Type">
48 <constant>application/json</constant>
50 <setHeader headerName="X-ONAP-RequestID">
51 <simple>${exchangeProperty[X-ONAP-RequestID]}
54 <setHeader headerName="X-ONAP-InvocationID">
55 <simple>${exchangeProperty[X-ONAP-InvocationID]}
58 <setHeader headerName="X-ONAP-PartnerName">
59 <simple>${exchangeProperty[X-ONAP-PartnerName]}
62 <log loggingLevel="INFO"
63 message="Endpoint to deploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}"></log>
65 uri="{{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}?bridgeEndpoint=true&useSystemProperties=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authUsername={{clamp.config.dcae.deployment.userName}}&authPassword={{clamp.config.dcae.deployment.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=300000&authenticationPreemptive=true&connectionClose=true" />
66 <convertBodyTo type="java.lang.String" />
67 <setProperty propertyName="dcaeResponse">
68 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
69 method="convertDcaeResponse(${body})" />
71 <setProperty propertyName="dcaeStatusUrl">
72 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
73 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
76 uri="bean:org.onap.clamp.policy.microservice.MicroServicePolicyService?method=updateDcaeDeploymentFields(${exchangeProperty[microServicePolicy]},${exchangeProperty[dcaeDeploymentId]},${exchangeProperty[dcaeStatusUrl]})" />
78 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLogForComponent('Deploy for the micro service: ${exchangeProperty[microServicePolicy].getName()} - ${header.CamelHttpResponseCode} : ${header.CamelHttpResponseText}','INFO','DCAE',${exchangeProperty[loopObject]})" />
81 <exception>java.lang.Exception</exception>
83 <constant>false</constant>
85 <setProperty propertyName="logMessage">
86 <simple>DEPLOY micro service failed
87 (MicroService name:${exchangeProperty[microServicePolicy].getName()}),
88 Dep-id:${exchangeProperty[dcaeDeploymentId]},
89 StatusUrl:${exchangeProperty[dcaeStatusUrl]})
92 <setProperty propertyName="logComponent">
95 <to uri="direct:dump-loop-log-http-response" />
98 <to uri="direct:reset-raise-http-exception-flag" />
100 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
104 <route id="deploy-loop-single-blueprint">
105 <from uri="direct:deploy-loop-single-blueprint" />
107 <log loggingLevel="INFO"
108 message="Deploying the loop: ${exchangeProperty[loopObject].getName()}" />
110 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Deploying the loop')" />
112 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
113 method="getDeployPayload(${exchangeProperty[loopObject]})" />
115 <setProperty propertyName="dcaeDeploymentId">
116 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
117 method="generateDeploymentId()" />
119 <setHeader headerName="CamelHttpMethod">
120 <constant>PUT</constant>
122 <setHeader headerName="Content-Type">
123 <constant>application/json</constant>
125 <setHeader headerName="X-ONAP-RequestID">
126 <simple>${exchangeProperty[X-ONAP-RequestID]}
129 <setHeader headerName="X-ONAP-InvocationID">
130 <simple>${exchangeProperty[X-ONAP-InvocationID]}
133 <setHeader headerName="X-ONAP-PartnerName">
134 <simple>${exchangeProperty[X-ONAP-PartnerName]}
137 <log loggingLevel="INFO"
138 message="Endpoint to deploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}"></log>
140 uri="{{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}?bridgeEndpoint=true&useSystemProperties=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authUsername={{clamp.config.dcae.deployment.userName}}&authPassword={{clamp.config.dcae.deployment.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=300000&authenticationPreemptive=true&connectionClose=true" />
141 <convertBodyTo type="java.lang.String" />
142 <setProperty propertyName="dcaeResponse">
143 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
144 method="convertDcaeResponse(${body})" />
148 <setProperty propertyName="dcaeStatusUrl">
149 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
150 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
153 uri="bean:org.onap.clamp.loop.LoopService?method=updateDcaeDeploymentFields(${exchangeProperty[loopObject]},${exchangeProperty[dcaeDeploymentId]},${exchangeProperty[dcaeStatusUrl]})" />
155 <to uri="direct:reset-raise-http-exception-flag" />
157 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
158 <setProperty propertyName="logMessage">
159 <simple>DEPLOY loop status
160 (Dep-id:${exchangeProperty[dcaeDeploymentId]},
161 StatusUrl:${exchangeProperty[dcaeStatusUrl]})
164 <setProperty propertyName="logComponent">
165 <simple>DCAE</simple>
167 <to uri="direct:dump-loop-log-http-response" />
171 <route id="undeploy-loop">
172 <from uri="direct:undeploy-loop" />
175 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getUniqueBlueprint()} == true
177 <to uri="direct:undeploy-loop-single-blueprint" />
180 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getUniqueBlueprint()} == false
182 <to uri="direct:undeploy-loop-multi-blueprint" />
186 <route id="undeploy-loop-multi-blueprint">
187 <from uri="direct:undeploy-loop-multi-blueprint" />
189 <log loggingLevel="INFO"
190 message="Undeploying the blueprints for loop: ${exchangeProperty[loopObject].getName()}" />
192 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Undeploying the loop with multiple blueprints')" />
194 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
196 <setProperty propertyName="microServicePolicy">
197 <simple>${body}</simple>
201 message="Processing Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
204 <simple>${exchangeProperty[microServicePolicy].getDcaeDeploymentId()} != null
207 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
208 method="getUndeployPayload(${exchangeProperty[microServicePolicy]})" />
210 <setHeader headerName="CamelHttpMethod">
211 <constant>DELETE</constant>
213 <setHeader headerName="Content-Type">
214 <constant>application/json</constant>
216 <setHeader headerName="X-ONAP-RequestID">
217 <simple>${exchangeProperty[X-ONAP-RequestID]}
220 <setHeader headerName="X-ONAP-InvocationID">
221 <simple>${exchangeProperty[X-ONAP-InvocationID]}
224 <setHeader headerName="X-ONAP-PartnerName">
225 <simple>${exchangeProperty[X-ONAP-PartnerName]}
228 <log loggingLevel="INFO"
229 message="Endpoint to undeploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[microServicePolicy].getDcaeDeploymentId()}"></log>
231 uri="{{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[microServicePolicy].getDcaeDeploymentId()}?bridgeEndpoint=true&useSystemProperties=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authUsername={{clamp.config.dcae.deployment.userName}}&authPassword={{clamp.config.dcae.deployment.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=300000&authenticationPreemptive=true&connectionClose=true" />
232 <convertBodyTo type="java.lang.String" />
233 <setProperty propertyName="dcaeResponse">
234 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
235 method="convertDcaeResponse(${body})" />
237 <setProperty propertyName="dcaeStatusUrl">
238 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
239 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
242 uri="bean:org.onap.clamp.policy.microservice.MicroServicePolicyService?method=updateDcaeDeploymentFields(${exchangeProperty[microServicePolicy]},${exchangeProperty[microServicePolicy].getDcaeDeploymentId()},${exchangeProperty[dcaeStatusUrl]})" />
244 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLogForComponent('Undeploy for the micro service: ${exchangeProperty[microServicePolicy].getName()} - ${header.CamelHttpResponseCode} : ${header.CamelHttpResponseText}','INFO','DCAE',${exchangeProperty[loopObject]})" />
247 <log loggingLevel="WARNING"
248 message="Cannot Undeploy for the micro service: ${exchangeProperty[microServicePolicy].getName()}, the Deployment ID does not exist !" />
250 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLogForComponent('Cannot Undeploy for the micro service: ${exchangeProperty[microServicePolicy].getName()}, the Deployment ID does not exist !','WARNING','DCAE',${exchangeProperty[loopObject]})" />
255 <exception>java.lang.Exception</exception>
257 <constant>false</constant>
259 <setProperty propertyName="logMessage">
260 <simple>UNDEPLOY micro service failed
261 (MicroService name:${exchangeProperty[microServicePolicy].getName()})
264 <setProperty propertyName="logComponent">
265 <simple>DCAE</simple>
267 <to uri="direct:dump-loop-log-http-response" />
270 <to uri="direct:reset-raise-http-exception-flag" />
272 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
276 <route id="undeploy-loop-single-blueprint">
277 <from uri="direct:undeploy-loop-single-blueprint" />
278 <log loggingLevel="INFO"
279 message="Undeploying the loop: ${exchangeProperty[loopObject].getName()} : ${exchangeProperty[loopObject].getDcaeDeploymentId()}" />
281 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Undeploying the loop')" />
284 <simple>${exchangeProperty[loopObject].getDcaeDeploymentId()}
289 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
290 method="getUndeployPayload(${exchangeProperty[loopObject]})" />
292 <setHeader headerName="CamelHttpMethod">
293 <constant>DELETE</constant>
295 <setHeader headerName="Content-Type">
296 <constant>application/json</constant>
299 <setHeader headerName="X-ONAP-RequestID">
300 <simple>${exchangeProperty[X-ONAP-RequestID]}
303 <setHeader headerName="X-ONAP-InvocationID">
304 <simple>${exchangeProperty[X-ONAP-InvocationID]}
307 <setHeader headerName="X-ONAP-PartnerName">
308 <simple>${exchangeProperty[X-ONAP-PartnerName]}
311 <log loggingLevel="INFO"
312 message="Endpoint to undeploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[loopObject].getDcaeDeploymentId()}"></log>
314 uri="{{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[loopObject].getDcaeDeploymentId()}?bridgeEndpoint=true&useSystemProperties=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authUsername={{clamp.config.dcae.deployment.userName}}&authPassword={{clamp.config.dcae.deployment.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=300000&authenticationPreemptive=true&connectionClose=true" />
315 <convertBodyTo type="java.lang.String" />
316 <setProperty propertyName="dcaeResponse">
317 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
318 method="convertDcaeResponse(${body})" />
320 <setProperty propertyName="dcaeStatusUrl">
321 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
322 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
325 uri="bean:org.onap.clamp.loop.LoopService?method=updateDcaeDeploymentFields(${exchangeProperty[loopObject]},${exchangeProperty[loopObject].getDcaeDeploymentId()},${exchangeProperty[dcaeStatusUrl]})" />
327 <to uri="direct:reset-raise-http-exception-flag" />
329 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
330 <setProperty propertyName="logMessage">
331 <simple>UNDEPLOY loop status</simple>
333 <setProperty propertyName="logComponent">
334 <simple>DCAE</simple>
336 <to uri="direct:dump-loop-log-http-response" />
341 <log loggingLevel="WARNING"
342 message="Cannot Undeploy for the loop: ${exchangeProperty[loopObject].getName()}, the Deployment ID does not exist !" />
344 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Cannot Undeploy for the loop: ${exchangeProperty[loopObject].getName()}, the Deployment ID does not exist !','WARNING',${exchangeProperty[loopObject]})" />
348 <route id="get-dcae-deployment-status">
349 <from uri="direct:get-dcae-deployment-status" />
350 <log loggingLevel="INFO"
351 message="Getting DCAE deployment status for loop: ${exchangeProperty[loopObject].getName()} - ${exchangeProperty[dcaeComponent].getComponentName()}" />
353 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting Deployment status')" />
355 <setHeader headerName="CamelHttpMethod">
356 <constant>GET</constant>
358 <setHeader headerName="X-ONAP-RequestID">
359 <simple>${exchangeProperty[X-ONAP-RequestID]}
362 <setHeader headerName="X-ONAP-InvocationID">
363 <simple>${exchangeProperty[X-ONAP-InvocationID]}
366 <setHeader headerName="X-ONAP-PartnerName">
367 <simple>${exchangeProperty[X-ONAP-PartnerName]}
370 <log loggingLevel="INFO"
371 message="Endpoint to query Closed Loop status: ${exchangeProperty[getStatusUrl]}"></log>
373 uri="${exchangeProperty[getStatusUrl]}?bridgeEndpoint=true&useSystemProperties=true&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authMethod=Basic&authUsername={{clamp.config.dcae.deployment.userName}}&authPassword={{clamp.config.dcae.deployment.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=30000&authenticationPreemptive=true&connectionClose=true" />
375 <to uri="direct:reset-raise-http-exception-flag" />
377 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
378 <setProperty propertyName="logMessage">
379 <simple>DCAE deployment status</simple>
381 <setProperty propertyName="logComponent">
382 <simple>DCAE</simple>
384 <to uri="direct:dump-loop-log-http-response" />
388 <route id="get-dcae-blueprint-inventory">
389 <from uri="direct:get-dcae-blueprint-inventory" />
390 <log loggingLevel="INFO"
391 message="Getting DCAE blueprint id in inventory" />
393 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting blueprint id in inventory')" />
395 <setHeader headerName="CamelHttpMethod">
396 <constant>GET</constant>
398 <setHeader headerName="X-ONAP-RequestID">
399 <simple>${exchangeProperty[X-ONAP-RequestID]}
402 <setHeader headerName="X-ONAP-InvocationID">
403 <simple>${exchangeProperty[X-ONAP-InvocationID]}
406 <setHeader headerName="X-ONAP-PartnerName">
407 <simple>${exchangeProperty[X-ONAP-PartnerName]}
410 <log loggingLevel="INFO"
411 message="Endpoint to query Dcae inventory Loop status: {{clamp.config.dcae.inventory.url}}/dcae-service-types?${header[CamelHttpQuery]}"></log>
413 uri="{{clamp.config.dcae.inventory.url}}/dcae-service-types?asdcResourceId=${exchangeProperty[blueprintResourceId]}&asdcServiceId=${exchangeProperty[blueprintServiceId]}&typeName=${exchangeProperty[blueprintName]}&bridgeEndpoint=true&useSystemProperties=true&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authMethod=Basic&authUsername={{clamp.config.dcae.deployment.userName}}&authPassword={{clamp.config.dcae.deployment.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=30000&authenticationPreemptive=true&connectionClose=true" />
414 <convertBodyTo type="java.lang.String" />
416 <to uri="direct:reset-raise-http-exception-flag" />
418 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
423 <route id="get-all-dcae-blueprint-inventory">
424 <from uri="direct:get-all-dcae-blueprint-inventory" />
425 <log loggingLevel="INFO"
426 message="Getting all DCAE blueprint from inventory" />
427 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting all blueprint from inventory')" />
429 <setHeader headerName="CamelHttpMethod">
430 <constant>GET</constant>
432 <setHeader headerName="X-ONAP-RequestID">
433 <simple>${exchangeProperty[X-ONAP-RequestID]}
436 <setHeader headerName="X-ONAP-InvocationID">
437 <simple>${exchangeProperty[X-ONAP-InvocationID]}
440 <setHeader headerName="X-ONAP-PartnerName">
441 <simple>${exchangeProperty[X-ONAP-PartnerName]}
444 <log loggingLevel="INFO"
445 message="Endpoint to query Blueprints from DCAE inventory: {{clamp.config.dcae.inventory.url}}/dcae-service-types?${header[CamelHttpQuery]}"></log>
446 <toD uri="{{clamp.config.dcae.inventory.url}}/dcae-service-types;bridgeEndpoint=true&useSystemProperties=true&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authMethod=Basic&authUsername={{clamp.config.dcae.deployment.userName}}&authPassword={{clamp.config.dcae.deployment.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=30000&authenticationPreemptive=true&connectionClose=true" />
447 <convertBodyTo type="java.lang.String" />
448 <setProperty propertyName="dcaeResponseList">
449 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
450 method="convertToDcaeInventoryResponse(${body})" />
453 <simple>${exchangeProperty[dcaeResponseList]}</simple>
454 <convertBodyTo type="org.onap.clamp.clds.model.dcae.DcaeInventoryResponse" />
455 <setProperty propertyName="dcaeResponse">
456 <simple>${body}</simple>
458 <to uri="bean:org.onap.clamp.clds.model.dcae.DcaeInventoryCache?method=addDcaeInventoryResponse(${exchangeProperty[dcaeResponse]})" />
461 <to uri="direct:reset-raise-http-exception-flag" />
462 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />