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().getBlueprint()} != null
8 <to uri="direct:deploy-loop-single-blueprint" />
11 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getBlueprint()} == null
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].getName()})" />
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]})" />
79 <exception>java.lang.Exception</exception>
81 <constant>false</constant>
83 <setProperty propertyName="logMessage">
84 <simple>DEPLOY micro service failed
85 (MicroService name:${exchangeProperty[microServicePolicy].getName()}),
86 Dep-id:${exchangeProperty[dcaeDeploymentId]},
87 StatusUrl:${exchangeProperty[dcaeStatusUrl]})
90 <setProperty propertyName="logComponent">
93 <to uri="direct:dump-loop-log-http-response" />
96 <to uri="direct:reset-raise-http-exception-flag" />
98 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
102 <route id="deploy-loop-single-blueprint">
103 <from uri="direct:deploy-loop-single-blueprint" />
105 <log loggingLevel="INFO"
106 message="Deploying the loop: ${exchangeProperty[loopObject].getName()}" />
108 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Deploying the loop')" />
110 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
111 method="getDeployPayload(${exchangeProperty[loopObject]})" />
113 <setProperty propertyName="dcaeDeploymentId">
114 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
115 method="generateDeploymentId()" />
117 <setHeader headerName="CamelHttpMethod">
118 <constant>PUT</constant>
120 <setHeader headerName="Content-Type">
121 <constant>application/json</constant>
123 <setHeader headerName="X-ONAP-RequestID">
124 <simple>${exchangeProperty[X-ONAP-RequestID]}
127 <setHeader headerName="X-ONAP-InvocationID">
128 <simple>${exchangeProperty[X-ONAP-InvocationID]}
131 <setHeader headerName="X-ONAP-PartnerName">
132 <simple>${exchangeProperty[X-ONAP-PartnerName]}
135 <log loggingLevel="INFO"
136 message="Endpoint to deploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}"></log>
138 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" />
139 <convertBodyTo type="java.lang.String" />
140 <setProperty propertyName="dcaeResponse">
141 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
142 method="convertDcaeResponse(${body})" />
146 <setProperty propertyName="dcaeStatusUrl">
147 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
148 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
151 uri="bean:org.onap.clamp.loop.LoopService?method=updateDcaeDeploymentFields(${exchangeProperty[loopObject]},${exchangeProperty[dcaeDeploymentId]},${exchangeProperty[dcaeStatusUrl]})" />
153 <to uri="direct:reset-raise-http-exception-flag" />
155 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
156 <setProperty propertyName="logMessage">
157 <simple>DEPLOY loop status
158 (Dep-id:${exchangeProperty[dcaeDeploymentId]},
159 StatusUrl:${exchangeProperty[dcaeStatusUrl]})
162 <setProperty propertyName="logComponent">
163 <simple>DCAE</simple>
165 <to uri="direct:dump-loop-log-http-response" />
169 <route id="undeploy-loop">
170 <from uri="direct:undeploy-loop" />
173 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getBlueprint()} != null
175 <to uri="direct:undeploy-loop-single-blueprint" />
178 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getBlueprint()} == null
180 <to uri="direct:undeploy-loop-multi-blueprint" />
184 <route id="undeploy-loop-multi-blueprint">
185 <from uri="direct:undeploy-loop-multi-blueprint" />
187 <log loggingLevel="INFO"
188 message="Undeploying the blueprints for loop: ${exchangeProperty[loopObject].getName()}" />
190 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Undeploying the loop with multiple blueprints')" />
192 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
194 <setProperty propertyName="microServicePolicy">
195 <simple>${body}</simple>
199 message="Processing Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
202 <simple>${exchangeProperty[microServicePolicy].getDcaeDeploymentId()} != null
205 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
206 method="getUndeployPayload(${exchangeProperty[microServicePolicy]})" />
208 <setHeader headerName="CamelHttpMethod">
209 <constant>DELETE</constant>
211 <setHeader headerName="Content-Type">
212 <constant>application/json</constant>
214 <setHeader headerName="X-ONAP-RequestID">
215 <simple>${exchangeProperty[X-ONAP-RequestID]}
218 <setHeader headerName="X-ONAP-InvocationID">
219 <simple>${exchangeProperty[X-ONAP-InvocationID]}
222 <setHeader headerName="X-ONAP-PartnerName">
223 <simple>${exchangeProperty[X-ONAP-PartnerName]}
226 <log loggingLevel="INFO"
227 message="Endpoint to undeploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[microServicePolicy].getDcaeDeploymentId()}"></log>
229 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" />
230 <convertBodyTo type="java.lang.String" />
231 <setProperty propertyName="dcaeResponse">
232 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
233 method="convertDcaeResponse(${body})" />
235 <setProperty propertyName="dcaeStatusUrl">
236 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
237 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
240 uri="bean:org.onap.clamp.policy.microservice.MicroServicePolicyService?method=updateDcaeDeploymentFields(${exchangeProperty[microServicePolicy]},${exchangeProperty[microServicePolicy].getDcaeDeploymentId()},${exchangeProperty[dcaeStatusUrl]})" />
243 <log loggingLevel="WARNING"
244 message="Cannot Undeploy for the micro service: ${exchangeProperty[microServicePolicy].getName()}, the Deployment ID does not exist !" />
246 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Cannot Undeploy for the micro service: ${exchangeProperty[microServicePolicy].getName()}, the Deployment ID does not exist !','WARNING',${exchangeProperty[loopObject]})" />
251 <exception>java.lang.Exception</exception>
253 <constant>false</constant>
255 <setProperty propertyName="logMessage">
256 <simple>UNDEPLOY micro service failed
257 (MicroService name:${exchangeProperty[microServicePolicy].getName()})
260 <setProperty propertyName="logComponent">
261 <simple>DCAE</simple>
263 <to uri="direct:dump-loop-log-http-response" />
266 <to uri="direct:reset-raise-http-exception-flag" />
268 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
272 <route id="undeploy-loop-single-blueprint">
273 <from uri="direct:undeploy-loop-single-blueprint" />
274 <log loggingLevel="INFO"
275 message="Undeploying the loop: ${exchangeProperty[loopObject].getName()} : ${exchangeProperty[loopObject].getDcaeDeploymentId()}" />
277 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Undeploying the loop')" />
280 <simple>${exchangeProperty[loopObject].getDcaeDeploymentId()}
285 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
286 method="getUndeployPayload(${exchangeProperty[loopObject]})" />
288 <setHeader headerName="CamelHttpMethod">
289 <constant>DELETE</constant>
291 <setHeader headerName="Content-Type">
292 <constant>application/json</constant>
295 <setHeader headerName="X-ONAP-RequestID">
296 <simple>${exchangeProperty[X-ONAP-RequestID]}
299 <setHeader headerName="X-ONAP-InvocationID">
300 <simple>${exchangeProperty[X-ONAP-InvocationID]}
303 <setHeader headerName="X-ONAP-PartnerName">
304 <simple>${exchangeProperty[X-ONAP-PartnerName]}
307 <log loggingLevel="INFO"
308 message="Endpoint to undeploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[loopObject].getDcaeDeploymentId()}"></log>
310 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" />
311 <convertBodyTo type="java.lang.String" />
312 <setProperty propertyName="dcaeResponse">
313 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
314 method="convertDcaeResponse(${body})" />
316 <setProperty propertyName="dcaeStatusUrl">
317 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
318 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
321 uri="bean:org.onap.clamp.loop.LoopService?method=updateDcaeDeploymentFields(${exchangeProperty[loopObject]},${exchangeProperty[loopObject].getDcaeDeploymentId()},${exchangeProperty[dcaeStatusUrl]})" />
323 <to uri="direct:reset-raise-http-exception-flag" />
325 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
326 <setProperty propertyName="logMessage">
327 <simple>UNDEPLOY loop status</simple>
329 <setProperty propertyName="logComponent">
330 <simple>DCAE</simple>
332 <to uri="direct:dump-loop-log-http-response" />
337 <log loggingLevel="WARNING"
338 message="Cannot Undeploy for the loop: ${exchangeProperty[loopObject].getName()}, the Deployment ID does not exist !" />
340 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]})" />
344 <route id="get-dcae-deployment-status">
345 <from uri="direct:get-dcae-deployment-status" />
346 <log loggingLevel="INFO"
347 message="Getting DCAE deployment status for loop: ${exchangeProperty[loopObject].getName()}" />
349 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting Deployment status')" />
351 <setHeader headerName="CamelHttpMethod">
352 <constant>GET</constant>
354 <setHeader headerName="X-ONAP-RequestID">
355 <simple>${exchangeProperty[X-ONAP-RequestID]}
358 <setHeader headerName="X-ONAP-InvocationID">
359 <simple>${exchangeProperty[X-ONAP-InvocationID]}
362 <setHeader headerName="X-ONAP-PartnerName">
363 <simple>${exchangeProperty[X-ONAP-PartnerName]}
366 <log loggingLevel="INFO"
367 message="Endpoint to query Closed Loop status: ${exchangeProperty[loopObject].getDcaeDeploymentStatusUrl()}"></log>
369 uri="${exchangeProperty[loopObject].getDcaeDeploymentStatusUrl()}?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" />
371 <to uri="direct:reset-raise-http-exception-flag" />
373 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
374 <setProperty propertyName="logMessage">
375 <simple>DCAE deployment status</simple>
377 <setProperty propertyName="logComponent">
378 <simple>DCAE</simple>
380 <to uri="direct:dump-loop-log-http-response" />
384 <route id="get-dcae-blueprint-inventory">
385 <from uri="direct:get-dcae-blueprint-inventory" />
386 <log loggingLevel="INFO"
387 message="Getting DCAE blueprint id in inventory" />
389 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting blueprint id in inventory')" />
391 <setHeader headerName="CamelHttpMethod">
392 <constant>GET</constant>
394 <setHeader headerName="X-ONAP-RequestID">
395 <simple>${exchangeProperty[X-ONAP-RequestID]}
398 <setHeader headerName="X-ONAP-InvocationID">
399 <simple>${exchangeProperty[X-ONAP-InvocationID]}
402 <setHeader headerName="X-ONAP-PartnerName">
403 <simple>${exchangeProperty[X-ONAP-PartnerName]}
406 <log loggingLevel="INFO"
407 message="Endpoint to query Dcae inventory Loop status: {{clamp.config.dcae.inventory.url}}/dcae-service-types?${header[CamelHttpQuery]}"></log>
409 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" />
410 <convertBodyTo type="java.lang.String" />
412 <to uri="direct:reset-raise-http-exception-flag" />
414 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
419 <route id="get-all-dcae-blueprint-inventory">
420 <from uri="direct:get-all-dcae-blueprint-inventory" />
421 <log loggingLevel="INFO"
422 message="Getting all DCAE blueprint from inventory" />
423 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting all blueprint from inventory')" />
425 <setHeader headerName="CamelHttpMethod">
426 <constant>GET</constant>
428 <setHeader headerName="X-ONAP-RequestID">
429 <simple>${exchangeProperty[X-ONAP-RequestID]}
432 <setHeader headerName="X-ONAP-InvocationID">
433 <simple>${exchangeProperty[X-ONAP-InvocationID]}
436 <setHeader headerName="X-ONAP-PartnerName">
437 <simple>${exchangeProperty[X-ONAP-PartnerName]}
440 <log loggingLevel="INFO"
441 message="Endpoint to query Blueprints from DCAE inventory: {{clamp.config.dcae.inventory.url}}/dcae-service-types?${header[CamelHttpQuery]}"></log>
442 <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" />
443 <convertBodyTo type="java.lang.String" />
444 <setProperty propertyName="dcaeResponseList">
445 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
446 method="convertToDcaeInventoryResponse(${body})" />
449 <simple>${exchangeProperty[dcaeResponseList]}</simple>
450 <convertBodyTo type="org.onap.clamp.clds.model.dcae.DcaeInventoryResponse" />
451 <setProperty propertyName="dcaeResponse">
452 <simple>${body}</simple>
454 <to uri="bean:org.onap.clamp.clds.model.dcae.DcaeInventoryCache?method=addDcaeInventoryResponse(${exchangeProperty[dcaeResponse]})" />
457 <to uri="direct:reset-raise-http-exception-flag" />
458 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />