1 <routes xmlns="http://camel.apache.org/schema/spring">
2 <route id="deploy-loop">
3 <from uri="direct:deploy-loop" />
7 message="Deploying the loop: ${exchangeProperty[loopObject].getName()}" />
9 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Deploying the loop')" />
12 ref="org.onap.clamp.loop.components.external.DcaeComponent"
13 method="getDeployPayload(${exchangeProperty[loopObject]})" />
15 <setProperty propertyName="dcaeDeploymentId">
17 ref="org.onap.clamp.loop.components.external.DcaeComponent"
18 method="generateDeploymentId()" />
20 <setHeader headerName="CamelHttpMethod">
21 <constant>PUT</constant>
23 <setHeader headerName="Content-Type">
24 <constant>application/json</constant>
26 <setHeader headerName="X-ONAP-RequestID">
27 <simple>${exchangeProperty[X-ONAP-RequestID]}
30 <setHeader headerName="X-ONAP-InvocationID">
31 <simple>${exchangeProperty[X-ONAP-InvocationID]}
34 <setHeader headerName="X-ONAP-PartnerName">
35 <simple>${exchangeProperty[X-ONAP-PartnerName]}
40 message="Endpoint to deploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}"></log>
42 uri="{{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}?bridgeEndpoint=true&useSystemProperties=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&httpClient.connectTimeout=10000&authUsername={{clamp.config.dcae.deployment.userName}}&authPassword={{clamp.config.dcae.deployment.password}}&connectionsPerRoute=3" />
43 <convertBodyTo type="java.lang.String" />
44 <setProperty propertyName="dcaeResponse">
46 ref="org.onap.clamp.loop.components.external.DcaeComponent"
47 method="convertDcaeResponse(${body})" />
49 <setProperty propertyName="dcaeStatusUrl">
51 ref="org.onap.clamp.loop.components.external.DcaeComponent"
52 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
55 uri="bean:org.onap.clamp.loop.LoopService?method=updateDcaeDeploymentFields(${exchangeProperty[loopObject]},${exchangeProperty[dcaeDeploymentId]},${exchangeProperty[dcaeStatusUrl]})" />
57 <to uri="direct:reset-raise-http-exception-flag" />
59 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
60 <setProperty propertyName="logMessage">
61 <simple>DEPLOY loop status
62 (Dep-id:${exchangeProperty[dcaeDeploymentId]},
63 StatusUrl:${exchangeProperty[dcaeStatusUrl]})
66 <to uri="direct:dump-loop-log-http-response" />
71 <route id="undeploy-loop">
72 <from uri="direct:undeploy-loop" />
75 message="Undeploying the loop: ${exchangeProperty[loopObject].getName()} : ${exchangeProperty[loopObject].getDcaeDeploymentId()}" />
77 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Undeploying the loop')" />
80 <simple>${exchangeProperty[loopObject].getDcaeDeploymentId()}
86 ref="org.onap.clamp.loop.components.external.DcaeComponent"
87 method="getUndeployPayload(${exchangeProperty[loopObject]})" />
89 <setHeader headerName="CamelHttpMethod">
90 <constant>DELETE</constant>
92 <setHeader headerName="Content-Type">
93 <constant>application/json</constant>
96 <setHeader headerName="X-ONAP-RequestID">
97 <simple>${exchangeProperty[X-ONAP-RequestID]}
100 <setHeader headerName="X-ONAP-InvocationID">
101 <simple>${exchangeProperty[X-ONAP-InvocationID]}
104 <setHeader headerName="X-ONAP-PartnerName">
105 <simple>${exchangeProperty[X-ONAP-PartnerName]}
110 message="Endpoint to undeploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[loopObject].getDcaeDeploymentId()}"></log>
112 uri="{{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[loopObject].getDcaeDeploymentId()}?bridgeEndpoint=true&useSystemProperties=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&httpClient.connectTimeout=10000&authUsername={{clamp.config.dcae.deployment.userName}}&authPassword={{clamp.config.dcae.deployment.password}}&connectionsPerRoute=3" />
113 <convertBodyTo type="java.lang.String" />
114 <setProperty propertyName="dcaeResponse">
116 ref="org.onap.clamp.loop.components.external.DcaeComponent"
117 method="convertDcaeResponse(${body})" />
119 <setProperty propertyName="dcaeStatusUrl">
121 ref="org.onap.clamp.loop.components.external.DcaeComponent"
122 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
125 uri="bean:org.onap.clamp.loop.LoopService?method=updateDcaeDeploymentFields(${exchangeProperty[loopObject]},${exchangeProperty[loopObject].getDcaeDeploymentId()},${exchangeProperty[dcaeStatusUrl]})" />
127 <to uri="direct:reset-raise-http-exception-flag" />
129 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
130 <setProperty propertyName="logMessage">
131 <simple>UNDEPLOY loop status</simple>
133 <to uri="direct:dump-loop-log-http-response" />
139 loggingLevel="WARNING"
140 message="Cannot Undeploy for the loop: ${exchangeProperty[loopObject].getName()}, the Deployment ID does not exist !" />
142 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]})" />
147 <route id="get-dcae-deployment-status">
148 <from uri="direct:get-dcae-deployment-status" />
151 message="Getting DCAE deployment status for loop: ${exchangeProperty[loopObject].getName()}" />
153 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting Deployment status')" />
155 <setHeader headerName="CamelHttpMethod">
156 <constant>GET</constant>
158 <setHeader headerName="X-ONAP-RequestID">
159 <simple>${exchangeProperty[X-ONAP-RequestID]}
162 <setHeader headerName="X-ONAP-InvocationID">
163 <simple>${exchangeProperty[X-ONAP-InvocationID]}
166 <setHeader headerName="X-ONAP-PartnerName">
167 <simple>${exchangeProperty[X-ONAP-PartnerName]}
172 message="Endpoint to query Closed Loop status: ${exchangeProperty[loopObject].getDcaeDeploymentStatusUrl()}"></log>
174 uri="${exchangeProperty[loopObject].getDcaeDeploymentStatusUrl()}?bridgeEndpoint=true&useSystemProperties=true&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&httpClient.connectTimeout=10000&authMethod=Basic&authUsername={{clamp.config.dcae.deployment.userName}}&authPassword={{clamp.config.dcae.deployment.password}}&connectionsPerRoute=3" />
176 <to uri="direct:reset-raise-http-exception-flag" />
178 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
179 <setProperty propertyName="logMessage">
180 <simple>DCAE deployment status</simple>
182 <to uri="direct:dump-loop-log-http-response" />