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 loop status
85 (Dep-id:${exchangeProperty[dcaeDeploymentId]},
86 StatusUrl:${exchangeProperty[dcaeStatusUrl]})
89 <setProperty propertyName="logComponent">
92 <to uri="direct:dump-loop-log-http-response" />
95 <to uri="direct:reset-raise-http-exception-flag" />
97 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
101 <route id="deploy-loop-single-blueprint">
102 <from uri="direct:deploy-loop-single-blueprint" />
104 <log loggingLevel="INFO"
105 message="Deploying the loop: ${exchangeProperty[loopObject].getName()}" />
107 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Deploying the loop')" />
109 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
110 method="getDeployPayload(${exchangeProperty[loopObject]})" />
112 <setProperty propertyName="dcaeDeploymentId">
113 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
114 method="generateDeploymentId()" />
116 <setHeader headerName="CamelHttpMethod">
117 <constant>PUT</constant>
119 <setHeader headerName="Content-Type">
120 <constant>application/json</constant>
122 <setHeader headerName="X-ONAP-RequestID">
123 <simple>${exchangeProperty[X-ONAP-RequestID]}
126 <setHeader headerName="X-ONAP-InvocationID">
127 <simple>${exchangeProperty[X-ONAP-InvocationID]}
130 <setHeader headerName="X-ONAP-PartnerName">
131 <simple>${exchangeProperty[X-ONAP-PartnerName]}
134 <log loggingLevel="INFO"
135 message="Endpoint to deploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}"></log>
137 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" />
138 <convertBodyTo type="java.lang.String" />
139 <setProperty propertyName="dcaeResponse">
140 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
141 method="convertDcaeResponse(${body})" />
145 <setProperty propertyName="dcaeStatusUrl">
146 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
147 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
150 uri="bean:org.onap.clamp.loop.LoopService?method=updateDcaeDeploymentFields(${exchangeProperty[loopObject]},${exchangeProperty[dcaeDeploymentId]},${exchangeProperty[dcaeStatusUrl]})" />
152 <to uri="direct:reset-raise-http-exception-flag" />
154 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
155 <setProperty propertyName="logMessage">
156 <simple>DEPLOY loop status
157 (Dep-id:${exchangeProperty[dcaeDeploymentId]},
158 StatusUrl:${exchangeProperty[dcaeStatusUrl]})
161 <setProperty propertyName="logComponent">
162 <simple>DCAE</simple>
164 <to uri="direct:dump-loop-log-http-response" />
168 <route id="undeploy-loop">
169 <from uri="direct:undeploy-loop" />
170 <log loggingLevel="INFO"
171 message="Undeploying the loop: ${exchangeProperty[loopObject].getName()} : ${exchangeProperty[loopObject].getDcaeDeploymentId()}" />
173 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Undeploying the loop')" />
176 <simple>${exchangeProperty[loopObject].getDcaeDeploymentId()}
181 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
182 method="getUndeployPayload(${exchangeProperty[loopObject]})" />
184 <setHeader headerName="CamelHttpMethod">
185 <constant>DELETE</constant>
187 <setHeader headerName="Content-Type">
188 <constant>application/json</constant>
191 <setHeader headerName="X-ONAP-RequestID">
192 <simple>${exchangeProperty[X-ONAP-RequestID]}
195 <setHeader headerName="X-ONAP-InvocationID">
196 <simple>${exchangeProperty[X-ONAP-InvocationID]}
199 <setHeader headerName="X-ONAP-PartnerName">
200 <simple>${exchangeProperty[X-ONAP-PartnerName]}
203 <log loggingLevel="INFO"
204 message="Endpoint to undeploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[loopObject].getDcaeDeploymentId()}"></log>
206 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" />
207 <convertBodyTo type="java.lang.String" />
208 <setProperty propertyName="dcaeResponse">
209 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
210 method="convertDcaeResponse(${body})" />
212 <setProperty propertyName="dcaeStatusUrl">
213 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
214 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
217 uri="bean:org.onap.clamp.loop.LoopService?method=updateDcaeDeploymentFields(${exchangeProperty[loopObject]},${exchangeProperty[loopObject].getDcaeDeploymentId()},${exchangeProperty[dcaeStatusUrl]})" />
219 <to uri="direct:reset-raise-http-exception-flag" />
221 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
222 <setProperty propertyName="logMessage">
223 <simple>UNDEPLOY loop status</simple>
225 <setProperty propertyName="logComponent">
226 <simple>DCAE</simple>
228 <to uri="direct:dump-loop-log-http-response" />
233 <log loggingLevel="WARNING"
234 message="Cannot Undeploy for the loop: ${exchangeProperty[loopObject].getName()}, the Deployment ID does not exist !" />
236 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]})" />
241 <route id="get-dcae-deployment-status">
242 <from uri="direct:get-dcae-deployment-status" />
243 <log loggingLevel="INFO"
244 message="Getting DCAE deployment status for loop: ${exchangeProperty[loopObject].getName()}" />
246 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting Deployment status')" />
248 <setHeader headerName="CamelHttpMethod">
249 <constant>GET</constant>
251 <setHeader headerName="X-ONAP-RequestID">
252 <simple>${exchangeProperty[X-ONAP-RequestID]}
255 <setHeader headerName="X-ONAP-InvocationID">
256 <simple>${exchangeProperty[X-ONAP-InvocationID]}
259 <setHeader headerName="X-ONAP-PartnerName">
260 <simple>${exchangeProperty[X-ONAP-PartnerName]}
263 <log loggingLevel="INFO"
264 message="Endpoint to query Closed Loop status: ${exchangeProperty[loopObject].getDcaeDeploymentStatusUrl()}"></log>
266 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" />
268 <to uri="direct:reset-raise-http-exception-flag" />
270 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
271 <setProperty propertyName="logMessage">
272 <simple>DCAE deployment status</simple>
274 <setProperty propertyName="logComponent">
275 <simple>DCAE</simple>
277 <to uri="direct:dump-loop-log-http-response" />
281 <route id="get-dcae-blueprint-inventory">
282 <from uri="direct:get-dcae-blueprint-inventory" />
283 <log loggingLevel="INFO"
284 message="Getting DCAE blueprint id in inventory" />
286 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting blueprint id in inventory')" />
288 <setHeader headerName="CamelHttpMethod">
289 <constant>GET</constant>
291 <setHeader headerName="X-ONAP-RequestID">
292 <simple>${exchangeProperty[X-ONAP-RequestID]}
295 <setHeader headerName="X-ONAP-InvocationID">
296 <simple>${exchangeProperty[X-ONAP-InvocationID]}
299 <setHeader headerName="X-ONAP-PartnerName">
300 <simple>${exchangeProperty[X-ONAP-PartnerName]}
303 <log loggingLevel="INFO"
304 message="Endpoint to query Dcae inventory Loop status: {{clamp.config.dcae.inventory.url}}/dcae-service-types?${header[CamelHttpQuery]}"></log>
306 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" />
307 <convertBodyTo type="java.lang.String" />
309 <to uri="direct:reset-raise-http-exception-flag" />
311 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />