1 <routes xmlns="http://camel.apache.org/schema/spring">
3 <from uri="direct:processSubmit" />
6 <simple> ${exchangeProperty.actionCd} == 'SUBMIT' ||
7 ${exchangeProperty.actionCd} == 'RESUBMIT'
10 uri="bean:org.onap.clamp.clds.client.CldsEventDelegate?method=addEvent(*,'INITIATED')" />
11 <to uri="bean:org.onap.clamp.clds.client.TcaPolicyDelegate" />
12 <to uri="bean:org.onap.clamp.clds.client.HolmesPolicyDelegate" />
14 <constant>30000</constant>
17 uri="bean:org.onap.clamp.clds.client.OperationalPolicyDelegate" />
18 <to uri="bean:org.onap.clamp.clds.client.GuardPolicyDelegate" />
20 uri="bean:org.onap.clamp.clds.client.CldsEventDelegate?method=addEvent(*,'COMPLETED')" />
23 <simple> ${exchangeProperty.actionCd} == 'DELETE'</simple>
25 uri="bean:org.onap.clamp.clds.client.CldsEventDelegate?method=addEvent(*,'INITIATED')" />
26 <to uri="bean:org.onap.clamp.clds.client.TcaPolicyDeleteDelegate" />
28 uri="bean:org.onap.clamp.clds.client.HolmesPolicyDeleteDelegate" />
30 <constant>30000</constant>
33 uri="bean:org.onap.clamp.clds.client.OperationalPolicyDeleteDelegate" />
35 uri="bean:org.onap.clamp.clds.client.GuardPolicyDeleteDelegate" />
36 <to uri="bean:org.onap.clamp.clds.client.ModelDeleteDelegate" />
38 uri="bean:org.onap.clamp.clds.client.CldsEventDelegate?method=addEvent(*,'COMPLETED')" />
41 <simple> ${exchangeProperty.actionCd} == 'UPDATE'</simple>
43 uri="bean:org.onap.clamp.clds.client.CldsEventDelegate?method=addEvent(*,'INITIATED')" />
44 <to uri="bean:org.onap.clamp.clds.client.TcaPolicyDelegate" />
45 <to uri="bean:org.onap.clamp.clds.client.HolmesPolicyDelegate" />
47 <constant>30000</constant>
50 uri="bean:org.onap.clamp.clds.client.OperationalPolicyDelegate" />
51 <to uri="bean:org.onap.clamp.clds.client.GuardPolicyDelegate" />
53 uri="bean:org.onap.clamp.clds.client.CldsEventDelegate?method=addEvent(*,'COMPLETED')" />
56 <simple> ${exchangeProperty.actionCd} == 'STOP'</simple>
58 uri="bean:org.onap.clamp.clds.client.CldsEventDelegate?method=addEvent(*,'INITIATED')" />
60 uri="bean:org.onap.clamp.clds.client.OperationalPolicyDeleteDelegate" />
62 uri="bean:org.onap.clamp.clds.client.GuardPolicyDeleteDelegate" />
64 uri="bean:org.onap.clamp.clds.client.CldsEventDelegate?method=addEvent(*,'COMPLETED')" />
67 <simple> ${exchangeProperty.actionCd} == 'RESTART'</simple>
69 uri="bean:org.onap.clamp.clds.client.CldsEventDelegate?method=addEvent(*,'INITIATED')" />
70 <to uri="bean:org.onap.clamp.clds.client.GuardPolicyDelegate" />
72 uri="bean:org.onap.clamp.clds.client.OperationalPolicyDelegate" />
74 uri="bean:org.onap.clamp.clds.client.CldsEventDelegate?method=addEvent(*,'COMPLETED')" />
79 <route id="load-loop">
80 <from uri="direct:load-loop" />
82 <simple>${header.loopName}</simple>
84 <setHeader headerName="LoopObject">
86 ref="org.onap.clamp.loop.LoopService"
91 <simple>${header.LoopObject} == null</simple>
92 <setHeader headerName="CamelHttpResponseCode">
93 <constant>404</constant>
96 loggingLevel="WARNING"
97 message="Loop not found in database: ${body}" />
101 <route id="create-micro-service-policy">
102 <from uri="direct:create-micro-service-policy" />
106 message="Creating Micro Service Policy: ${header.microServicePolicy.getName()}" />
108 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Create Micro Service Policy')" />
110 <simple>${header.microServicePolicy.createPolicyPayload()}
113 <setHeader headerName="CamelHttpMethod">
114 <constant>POST</constant>
116 <setHeader headerName="Content-Type">
117 <constant>application/json</constant>
119 <setHeader headerName="CamelHttpUri">
120 <simple>{{clamp.config.policy.url}}/policy/api/v1/policyTypes/${header.microServicePolicy.getModelType()}/versions/1.0.0/policies
123 <setHeader headerName="X-ONAP-RequestID">
124 <simple>${header.X-ONAP-REAUESTID}
127 <setHeader headerName="X-ONAP-InvocationID">
128 <simple>${header.X-ONAP-InvocationID}
131 <setHeader headerName="X-ONAP-PartnerName">
132 <simple>${header.X-ONAP-PartnerName}
137 message="Endpoint to create microservice policy: ${header.CamelHttpMethod} ${header.CamelHttpUri}"></log>
139 uri="http4://policyhost:8085?mapHttpMessageHeaders=false&throwExceptionOnFailure=${header.RaiseHttpExceptionFlag}&httpClient.connectTimeout=10000&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
141 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('MicroService policy created successfully','INFO',${header.LoopObject})" />
142 <to uri="direct:reset-raise-http-exception-flag" />
143 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
145 <route id="delete-micro-service-policy">
146 <from uri="direct:delete-micro-service-policy" />
150 message="Deleting Micro Service Policy: ${header.microServicePolicy.getName()}" />
152 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Delete Micro Service Policy')" />
154 <constant>null</constant>
156 <setHeader headerName="CamelHttpMethod">
157 <constant>DELETE</constant>
159 <setHeader headerName="CamelHttpUri">
160 <simple>{{clamp.config.policy.url}}/policy/api/v1/policyTypes/${header.microServicePolicy.getModelType()}/versions/1.0.0/policies/${header.microServicePolicy.getName()}
163 <setHeader headerName="X-ONAP-RequestID">
164 <simple>${header.X-ONAP-REAUESTID}
167 <setHeader headerName="X-ONAP-InvocationID">
168 <simple>${header.X-ONAP-InvocationID}
171 <setHeader headerName="X-ONAP-PartnerName">
172 <simple>${header.X-ONAP-PartnerName}
177 message="Endpoint to delete microservice policy: ${header.CamelHttpMethod} ${header.CamelHttpUri}"></log>
179 uri="http4://policyhost:8085?mapHttpMessageHeaders=false&throwExceptionOnFailure=${header.RaiseHttpExceptionFlag}&httpClient.connectTimeout=10000&deleteWithBody=false&mapHttpMessageBody=false&mapHttpMessageFormUrlEncodedBody=false&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
181 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('MicroService policy deleted successfully','INFO',${header.LoopObject})" />
182 <to uri="direct:reset-raise-http-exception-flag" />
183 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
186 <route id="create-operational-policy">
187 <from uri="direct:create-operational-policy" />
191 message="Creating Operational Policy: ${header.operationalPolicy.getName()}" />
193 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Create Operational Policy')" />
195 <simple>${header.operationalPolicy.createPolicyPayload()}
198 <setHeader headerName="CamelHttpMethod">
199 <constant>POST</constant>
201 <setHeader headerName="Content-Type">
202 <constant>application/yaml; legacy-version</constant>
204 <setHeader headerName="CamelHttpUri">
205 <simple>{{clamp.config.policy.url}}/policy/api/v1/policyTypes/onap.policies.controloop.operational/versions/1.0.0/policies
208 <setHeader headerName="X-ONAP-RequestID">
209 <simple>${header.X-ONAP-REAUESTID}
212 <setHeader headerName="X-ONAP-InvocationID">
213 <simple>${header.X-ONAP-InvocationID}
216 <setHeader headerName="X-ONAP-PartnerName">
217 <simple>${header.X-ONAP-PartnerName}
222 message="Endpoint to create operational policy: ${header.CamelHttpMethod} ${header.CamelHttpUri}"></log>
224 uri="http4://policyhost:8085?mapHttpMessageHeaders=false&throwExceptionOnFailure=${header.RaiseHttpExceptionFlag}&httpClient.connectTimeout=10000&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
226 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Operational policy created successfully','INFO',${header.LoopObject})" />
227 <to uri="direct:reset-raise-http-exception-flag" />
228 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
230 <route id="delete-operational-policy">
231 <from uri="direct:delete-operational-policy" />
235 message="Deleting Operational Policy: ${header.operationalPolicy.getName()}" />
237 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Delete Operational Policy')" />
239 <constant>null</constant>
241 <setHeader headerName="CamelHttpMethod">
242 <constant>DELETE</constant>
244 <setHeader headerName="CamelHttpUri">
245 <simple>{{clamp.config.policy.url}}/policy/api/v1/policyTypes/onap.policies.controloop.operational/versions/1.0.0/policies/${header.operationalPolicy.getName()}
248 <setHeader headerName="X-ONAP-RequestID">
249 <simple>${header.X-ONAP-REAUESTID}
252 <setHeader headerName="X-ONAP-InvocationID">
253 <simple>${header.X-ONAP-InvocationID}
256 <setHeader headerName="X-ONAP-PartnerName">
257 <simple>${header.X-ONAP-PartnerName}
262 message="Endpoint to delete operational policy: ${header.CamelHttpMethod} ${header.CamelHttpUri}"></log>
264 uri="http4://policyhost:8085?mapHttpMessageHeaders=false&throwExceptionOnFailure=${header.RaiseHttpExceptionFlag}&httpClient.connectTimeout=10000&deleteWithBody=false&mapHttpMessageBody=false&mapHttpMessageFormUrlEncodedBody=false&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
266 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Operational policy deleted successfully','INFO',${header.LoopObject})" />
267 <to uri="direct:reset-raise-http-exception-flag" />
268 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
271 <route id="create-guard-policy">
272 <from uri="direct:create-guard-policy" />
276 message="Creating Guard Policy: ${header.guardPolicy.getKey()}" />
278 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Create Guard Policy')" />
280 <simple>${header.guardPolicy.getValue()}
283 <setHeader headerName="CamelHttpMethod">
284 <constant>POST</constant>
286 <setHeader headerName="Content-Type">
287 <constant>application/json</constant>
289 <setHeader headerName="CamelHttpUri">
290 <simple>{{clamp.config.policy.url}}/policy/api/v1/policyTypes/onap.policies.controlloop.Guard/versions/1.0.0/policies
293 <setHeader headerName="X-ONAP-RequestID">
294 <simple>${header.X-ONAP-REAUESTID}
297 <setHeader headerName="X-ONAP-InvocationID">
298 <simple>${header.X-ONAP-InvocationID}
301 <setHeader headerName="X-ONAP-PartnerName">
302 <simple>${header.X-ONAP-PartnerName}
307 message="Endpoint to create guard policy: ${header.CamelHttpMethod} ${header.CamelHttpUri}"></log>
309 uri="http4://policyhost:8085?mapHttpMessageHeaders=false&throwExceptionOnFailure=${header.RaiseHttpExceptionFlag}&httpClient.connectTimeout=10000&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
311 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Guard policy created successfully','INFO',${header.LoopObject})" />
312 <to uri="direct:reset-raise-http-exception-flag" />
313 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
315 <route id="delete-guard-policy">
316 <from uri="direct:delete-guard-policy" />
320 message="Deleting Guard Policy: ${header.guardPolicy.getKey()}" />
322 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Delete Guard Policy')" />
324 <constant>null</constant>
326 <setHeader headerName="CamelHttpMethod">
327 <constant>DELETE</constant>
329 <setHeader headerName="CamelHttpUri">
330 <simple>{{clamp.config.policy.url}}/policy/api/v1/policyTypes/onap.policies.controlloop.Guard/versions/1.0.0/policies/${header.guardPolicy.getKey()}
333 <setHeader headerName="X-ONAP-RequestID">
334 <simple>${header.X-ONAP-REAUESTID}
337 <setHeader headerName="X-ONAP-InvocationID">
338 <simple>${header.X-ONAP-InvocationID}
341 <setHeader headerName="X-ONAP-PartnerName">
342 <simple>${header.X-ONAP-PartnerName}
347 message="Endpoint to delete guard policy: ${header.CamelHttpMethod} ${header.CamelHttpUri}"></log>
349 uri="http4://policyhost:8085?throwExceptionOnFailure=${header.RaiseHttpExceptionFlag}&httpClient.connectTimeout=10000&deleteWithBody=false&mapHttpMessageBody=false&mapHttpMessageFormUrlEncodedBody=false&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
351 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Guard policy deleted successfully','INFO',${header.LoopObject})" />
352 <to uri="direct:reset-raise-http-exception-flag" />
353 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
355 <route id="add-all-to-active-pdp-group">
356 <from uri="direct:add-all-to-active-pdp-group" />
360 message="Adding loop policies to PDP Group: ${header.LoopObject.getName()}" />
362 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Add policies to PDP group')" />
364 <simple>${header.LoopObject.createPoliciesPayloadPdpGroup()}
367 <setHeader headerName="CamelHttpMethod">
368 <constant>POST</constant>
370 <setHeader headerName="Content-Type">
371 <constant>application/json</constant>
373 <setHeader headerName="CamelHttpUri">
374 <simple>{{clamp.config.policy.url}}/policy/pap/v1/pdps
377 <setHeader headerName="X-ONAP-RequestID">
378 <simple>${header.X-ONAP-REAUESTID}
381 <setHeader headerName="X-ONAP-InvocationID">
382 <simple>${header.X-ONAP-InvocationID}
385 <setHeader headerName="X-ONAP-PartnerName">
386 <simple>${header.X-ONAP-PartnerName}
391 message="Endpoint to add policies to PDP Group: ${header.CamelHttpMethod} ${header.CamelHttpUri}"></log>
393 uri="http4://policyhost:8085?mapHttpMessageHeaders=false&throwExceptionOnFailure=${header.RaiseHttpExceptionFlag}&httpClient.connectTimeout=10000&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
395 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Policies pushed to PDP Group successfully','INFO',${header.LoopObject})" />
396 <to uri="direct:reset-raise-http-exception-flag" />
397 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
400 <route id="remove-all-policy-from-active-pdp-group">
401 <from uri="direct:remove-all-policy-from-active-pdp-group" />
404 message="Removing policies from active PDP group for loop: ${header.LoopObject.getName()}" />
406 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Removing policies PDP group')" />
408 <simple>${header.LoopObject.listPolicyNamesPdpGroup()}</simple>
409 <setHeader headerName="PolicyName">
410 <simple>${body}</simple>
413 <constant>null</constant>
415 <setHeader headerName="CamelHttpMethod">
416 <constant>DELETE</constant>
418 <setHeader headerName="CamelHttpUri">
419 <simple>{{clamp.config.policy.url}}/pdps/policies/${header.PolicyName}/versions/1.0.0
422 <setHeader headerName="X-ONAP-RequestID">
423 <simple>${header.X-ONAP-REAUESTID}
426 <setHeader headerName="X-ONAP-InvocationID">
427 <simple>${header.X-ONAP-InvocationID}
430 <setHeader headerName="X-ONAP-PartnerName">
431 <simple>${header.X-ONAP-PartnerName}
436 message="Endpoint to delete policy from PDP Group: ${header.CamelHttpMethod} ${header.CamelHttpUri}"></log>
438 uri="http4://policyhost:8085?mapHttpMessageHeaders=false&throwExceptionOnFailure=${header.RaiseHttpExceptionFlag}&httpClient.connectTimeout=10000&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
440 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog(${header.PolicyName}' Policy removed from PDP Group successfully','INFO',${header.LoopObject})" />
442 <to uri="direct:reset-raise-http-exception-flag" />
443 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
445 <route id="reset-raise-http-exception-flag">
446 <from uri="direct:reset-raise-http-exception-flag" />
447 <setHeader headerName="RaiseHttpExceptionFlag">
448 <simple resultType="java.lang.Boolean">true</simple>