1 <routes xmlns="http://camel.apache.org/schema/spring">
2 <route id="deploy-loop">
3 <from uri="direct:deploy-loop" />
5 <log loggingLevel="INFO"
6 message="Deploying the loop: ${exchangeProperty[loopObject].getName()}" />
8 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Deploying the loop')" />
10 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
11 method="getDeployPayload(${exchangeProperty[loopObject]})" />
13 <setProperty propertyName="dcaeDeploymentId">
14 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
15 method="generateDeploymentId()" />
17 <setHeader headerName="CamelHttpMethod">
18 <constant>PUT</constant>
20 <setHeader headerName="Content-Type">
21 <constant>application/json</constant>
23 <setHeader headerName="X-ONAP-RequestID">
24 <simple>${exchangeProperty[X-ONAP-RequestID]}
27 <setHeader headerName="X-ONAP-InvocationID">
28 <simple>${exchangeProperty[X-ONAP-InvocationID]}
31 <setHeader headerName="X-ONAP-PartnerName">
32 <simple>${exchangeProperty[X-ONAP-PartnerName]}
35 <log loggingLevel="INFO"
36 message="Endpoint to deploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}"></log>
38 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" />
39 <convertBodyTo type="java.lang.String" />
40 <setProperty propertyName="dcaeResponse">
41 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
42 method="convertDcaeResponse(${body})" />
44 <setProperty propertyName="dcaeStatusUrl">
45 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
46 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
49 uri="bean:org.onap.clamp.loop.LoopService?method=updateDcaeDeploymentFields(${exchangeProperty[loopObject]},${exchangeProperty[dcaeDeploymentId]},${exchangeProperty[dcaeStatusUrl]})" />
51 <to uri="direct:reset-raise-http-exception-flag" />
53 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
54 <setProperty propertyName="logMessage">
55 <simple>DEPLOY loop status
56 (Dep-id:${exchangeProperty[dcaeDeploymentId]},
57 StatusUrl:${exchangeProperty[dcaeStatusUrl]})
60 <setProperty propertyName="logComponent">
63 <to uri="direct:dump-loop-log-http-response" />
68 <route id="undeploy-loop">
69 <from uri="direct:undeploy-loop" />
70 <log loggingLevel="INFO"
71 message="Undeploying the loop: ${exchangeProperty[loopObject].getName()} : ${exchangeProperty[loopObject].getDcaeDeploymentId()}" />
73 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Undeploying the loop')" />
76 <simple>${exchangeProperty[loopObject].getDcaeDeploymentId()}
81 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
82 method="getUndeployPayload(${exchangeProperty[loopObject]})" />
84 <setHeader headerName="CamelHttpMethod">
85 <constant>DELETE</constant>
87 <setHeader headerName="Content-Type">
88 <constant>application/json</constant>
91 <setHeader headerName="X-ONAP-RequestID">
92 <simple>${exchangeProperty[X-ONAP-RequestID]}
95 <setHeader headerName="X-ONAP-InvocationID">
96 <simple>${exchangeProperty[X-ONAP-InvocationID]}
99 <setHeader headerName="X-ONAP-PartnerName">
100 <simple>${exchangeProperty[X-ONAP-PartnerName]}
103 <log loggingLevel="INFO"
104 message="Endpoint to undeploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[loopObject].getDcaeDeploymentId()}"></log>
106 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" />
107 <convertBodyTo type="java.lang.String" />
108 <setProperty propertyName="dcaeResponse">
109 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
110 method="convertDcaeResponse(${body})" />
112 <setProperty propertyName="dcaeStatusUrl">
113 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
114 method="getStatusUrl(${exchangeProperty[dcaeResponse]})" />
117 uri="bean:org.onap.clamp.loop.LoopService?method=updateDcaeDeploymentFields(${exchangeProperty[loopObject]},${exchangeProperty[loopObject].getDcaeDeploymentId()},${exchangeProperty[dcaeStatusUrl]})" />
119 <to uri="direct:reset-raise-http-exception-flag" />
121 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
122 <setProperty propertyName="logMessage">
123 <simple>UNDEPLOY loop status</simple>
125 <setProperty propertyName="logComponent">
126 <simple>DCAE</simple>
128 <to uri="direct:dump-loop-log-http-response" />
133 <log loggingLevel="WARNING"
134 message="Cannot Undeploy for the loop: ${exchangeProperty[loopObject].getName()}, the Deployment ID does not exist !" />
136 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]})" />
141 <route id="get-dcae-deployment-status">
142 <from uri="direct:get-dcae-deployment-status" />
143 <log loggingLevel="INFO"
144 message="Getting DCAE deployment status for loop: ${exchangeProperty[loopObject].getName()}" />
146 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting Deployment status')" />
148 <setHeader headerName="CamelHttpMethod">
149 <constant>GET</constant>
151 <setHeader headerName="X-ONAP-RequestID">
152 <simple>${exchangeProperty[X-ONAP-RequestID]}
155 <setHeader headerName="X-ONAP-InvocationID">
156 <simple>${exchangeProperty[X-ONAP-InvocationID]}
159 <setHeader headerName="X-ONAP-PartnerName">
160 <simple>${exchangeProperty[X-ONAP-PartnerName]}
163 <log loggingLevel="INFO"
164 message="Endpoint to query Closed Loop status: ${exchangeProperty[loopObject].getDcaeDeploymentStatusUrl()}"></log>
166 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" />
168 <to uri="direct:reset-raise-http-exception-flag" />
170 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
171 <setProperty propertyName="logMessage">
172 <simple>DCAE deployment status</simple>
174 <setProperty propertyName="logComponent">
175 <simple>DCAE</simple>
177 <to uri="direct:dump-loop-log-http-response" />
181 <route id="get-dcae-blueprint-inventory">
182 <from uri="direct:get-dcae-blueprint-inventory" />
183 <log loggingLevel="INFO"
184 message="Getting DCAE blueprint id in inventory" />
186 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting blueprint id in inventory')" />
188 <setHeader headerName="CamelHttpMethod">
189 <constant>GET</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 query Dcae inventory Loop status: {{clamp.config.dcae.inventory.url}}/dcae-service-types?${header[CamelHttpQuery]}"></log>
206 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" />
207 <convertBodyTo type="java.lang.String" />
209 <to uri="direct:reset-raise-http-exception-flag" />
211 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
216 <route id="get-all-dcae-blueprint-inventory">
217 <from uri="direct:get-all-dcae-blueprint-inventory" />
218 <log loggingLevel="INFO"
219 message="Getting all DCAE blueprint from inventory" />
220 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting all blueprint from inventory')" />
222 <setHeader headerName="CamelHttpMethod">
223 <constant>GET</constant>
225 <setHeader headerName="X-ONAP-RequestID">
226 <simple>${exchangeProperty[X-ONAP-RequestID]}
229 <setHeader headerName="X-ONAP-InvocationID">
230 <simple>${exchangeProperty[X-ONAP-InvocationID]}
233 <setHeader headerName="X-ONAP-PartnerName">
234 <simple>${exchangeProperty[X-ONAP-PartnerName]}
237 <log loggingLevel="INFO"
238 message="Endpoint to query Blueprints from DCAE inventory: {{clamp.config.dcae.inventory.url}}/dcae-service-types?${header[CamelHttpQuery]}"></log>
239 <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" />
240 <convertBodyTo type="java.lang.String" />
241 <setProperty propertyName="dcaeResponseList">
242 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
243 method="convertToDcaeInventoryResponse(${body})" />
246 <simple>${exchangeProperty[dcaeResponseList]}</simple>
247 <convertBodyTo type="org.onap.clamp.clds.model.dcae.DcaeInventoryResponse" />
248 <setProperty propertyName="dcaeResponse">
249 <simple>${body}</simple>
251 <to uri="bean:org.onap.clamp.clds.model.dcae.DcaeInventoryCache?method=addDcaeInventoryResponse(${exchangeProperty[dcaeResponse]})" />
254 <to uri="direct:reset-raise-http-exception-flag" />
255 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />