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 <setProperty propertyName="loopObject">
86 ref="org.onap.clamp.loop.LoopService"
91 <simple>${exchangeProperty[loopObject]} == null</simple>
92 <setHeader headerName="CamelHttpResponseCode">
93 <constant>404</constant>
96 loggingLevel="WARNING"
97 message="Loop not found in database: ${body}" />
102 <route id="create-micro-service-policy">
103 <from uri="direct:create-micro-service-policy" />
107 message="Creating Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
109 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Create Micro Service Policy')" />
111 <simple>${exchangeProperty[microServicePolicy].createPolicyPayload()}
114 <setHeader headerName="CamelHttpMethod">
115 <constant>POST</constant>
117 <setHeader headerName="Content-Type">
118 <constant>application/json</constant>
120 <setHeader headerName="X-ONAP-RequestID">
121 <simple>${exchangeProperty[X-ONAP-RequestID]}
124 <setHeader headerName="X-ONAP-InvocationID">
125 <simple>${exchangeProperty[X-ONAP-InvocationID]}
128 <setHeader headerName="X-ONAP-PartnerName">
129 <simple>${exchangeProperty[X-ONAP-PartnerName]}
134 message="Endpoint to create microservice policy: {{clamp.config.policy.url}}/policy/api/v1/policytypes/${exchangeProperty[microServicePolicy].getModelType()}/versions/1.0.0/policies"></log>
136 uri="{{clamp.config.policy.url}}/policy/api/v1/policytypes/${exchangeProperty[microServicePolicy].getModelType()}/versions/1.0.0/policies?bridgeEndpoint=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&httpClient.connectTimeout=10000&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
138 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('MicroService policy created successfully','INFO',${exchangeProperty[loopObject]})" />
139 <to uri="direct:reset-raise-http-exception-flag" />
141 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
144 <route id="delete-micro-service-policy">
145 <from uri="direct:delete-micro-service-policy" />
149 message="Deleting Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
151 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Delete Micro Service Policy')" />
153 <constant>null</constant>
155 <setHeader headerName="CamelHttpMethod">
156 <constant>DELETE</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 delete microservice policy: {{clamp.config.policy.url}}/policy/api/v1/policytypes/${exchangeProperty[microServicePolicy].getModelType()}/versions/1.0.0/policies/${exchangeProperty[microServicePolicy].getName()}"></log>
174 uri="{{clamp.config.policy.url}}/policy/api/v1/policytypes/${exchangeProperty[microServicePolicy].getModelType()}/versions/1.0.0/policies/${exchangeProperty[microServicePolicy].getName()}?bridgeEndpoint=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&httpClient.connectTimeout=10000&deleteWithBody=false&mapHttpMessageBody=false&mapHttpMessageFormUrlEncodedBody=false&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
176 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('MicroService policy deleted successfully','INFO',${exchangeProperty[loopObject]})" />
177 <to uri="direct:reset-raise-http-exception-flag" />
179 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
182 <route id="create-operational-policy">
183 <from uri="direct:create-operational-policy" />
187 message="Creating Operational Policy: ${exchangeProperty[operationalPolicy].getName()}" />
189 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Create Operational Policy')" />
191 <simple>${exchangeProperty[operationalPolicy].createPolicyPayload()}
194 <setHeader headerName="CamelHttpMethod">
195 <constant>POST</constant>
197 <setHeader headerName="Content-Type">
198 <constant>application/yaml; legacy-version</constant>
200 <setHeader headerName="X-ONAP-RequestID">
201 <simple>${exchangeProperty[X-ONAP-RequestID]}
204 <setHeader headerName="X-ONAP-InvocationID">
205 <simple>${exchangeProperty[X-ONAP-InvocationID]}
208 <setHeader headerName="X-ONAP-PartnerName">
209 <simple>${exchangeProperty[X-ONAP-PartnerName]}
214 message="Endpoint to create operational policy: {{clamp.config.policy.url}}/policy/api/v1/policytypes/onap.policies.controlloop.operational/versions/1.0.0/policies"></log>
216 uri="{{clamp.config.policy.url}}/policy/api/v1/policytypes/onap.policies.controlloop.operational/versions/1.0.0/policies?bridgeEndpoint=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&httpClient.connectTimeout=10000&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
218 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Operational policy created successfully','INFO',${exchangeProperty[loopObject]})" />
219 <to uri="direct:reset-raise-http-exception-flag" />
221 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
224 <route id="delete-operational-policy">
225 <from uri="direct:delete-operational-policy" />
229 message="Deleting Operational Policy: ${exchangeProperty[operationalPolicy].getName()}" />
231 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Delete Operational Policy')" />
233 <constant>null</constant>
235 <setHeader headerName="CamelHttpMethod">
236 <constant>DELETE</constant>
238 <setHeader headerName="X-ONAP-RequestID">
239 <simple>${exchangeProperty[X-ONAP-RequestID]}
242 <setHeader headerName="X-ONAP-InvocationID">
243 <simple>${exchangeProperty[X-ONAP-InvocationID]}
246 <setHeader headerName="X-ONAP-PartnerName">
247 <simple>${exchangeProperty[X-ONAP-PartnerName]}
252 message="Endpoint to delete operational policy: {{clamp.config.policy.url}}/policy/api/v1/policytypes/onap.policies.controlloop.operational/versions/1.0.0/policies/${exchangeProperty[operationalPolicy].getName()}"></log>
254 uri="{{clamp.config.policy.url}}/policy/api/v1/policytypes/onap.policies.controlloop.operational/versions/1.0.0/policies/${exchangeProperty[operationalPolicy].getName()}?bridgeEndpoint=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&httpClient.connectTimeout=10000&deleteWithBody=false&mapHttpMessageBody=false&mapHttpMessageFormUrlEncodedBody=false&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
256 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Operational policy deleted successfully','INFO',${exchangeProperty[loopObject]})" />
257 <to uri="direct:reset-raise-http-exception-flag" />
259 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
262 <route id="create-guard-policy">
263 <from uri="direct:create-guard-policy" />
267 message="Creating Guard Policy: ${exchangeProperty[guardPolicy].getKey()}" />
269 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Create Guard Policy')" />
271 <simple>${exchangeProperty[guardPolicy].getValue()}
274 <setHeader headerName="CamelHttpMethod">
275 <constant>POST</constant>
277 <setHeader headerName="Content-Type">
278 <constant>application/json</constant>
280 <setHeader headerName="X-ONAP-RequestID">
281 <simple>${exchangeProperty[X-ONAP-RequestID]}
284 <setHeader headerName="X-ONAP-InvocationID">
285 <simple>${exchangeProperty[X-ONAP-InvocationID]}
288 <setHeader headerName="X-ONAP-PartnerName">
289 <simple>${exchangeProperty[X-ONAP-PartnerName]}
294 message="Endpoint to create guard policy: {{clamp.config.policy.url}}/policy/api/v1/policytypes/onap.policies.controlloop.Guard/versions/1.0.0/policies"></log>
296 uri="{{clamp.config.policy.url}}/policy/api/v1/policytypes/onap.policies.controlloop.Guard/versions/1.0.0/policies?bridgeEndpoint=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&httpClient.connectTimeout=10000&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
298 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Guard policy created successfully','INFO',${exchangeProperty[loopObject]})" />
299 <to uri="direct:reset-raise-http-exception-flag" />
301 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
304 <route id="delete-guard-policy">
305 <from uri="direct:delete-guard-policy" />
309 message="Deleting Guard Policy: ${exchangeProperty[guardPolicy].getKey()}" />
311 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Delete Guard Policy')" />
313 <constant>null</constant>
315 <setHeader headerName="CamelHttpMethod">
316 <constant>DELETE</constant>
318 <setHeader headerName="X-ONAP-RequestID">
319 <simple>${exchangeProperty[X-ONAP-RequestID]}
322 <setHeader headerName="X-ONAP-InvocationID">
323 <simple>${exchangeProperty[X-ONAP-InvocationID]}
326 <setHeader headerName="X-ONAP-PartnerName">
327 <simple>${exchangeProperty[X-ONAP-PartnerName]}
332 message="Endpoint to delete guard policy: {{clamp.config.policy.url}}/policy/api/v1/policytypes/onap.policies.controlloop.Guard/versions/1.0.0/policies/${exchangeProperty[guardPolicy].getKey()}"></log>
334 uri="{{clamp.config.policy.url}}/policy/api/v1/policytypes/onap.policies.controlloop.Guard/versions/1.0.0/policies/${exchangeProperty[guardPolicy].getKey()}?bridgeEndpoint=true&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&httpClient.connectTimeout=10000&deleteWithBody=false&mapHttpMessageBody=false&mapHttpMessageFormUrlEncodedBody=false&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
336 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Guard policy deleted successfully','INFO',${exchangeProperty[loopObject]})" />
337 <to uri="direct:reset-raise-http-exception-flag" />
339 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
342 <route id="add-all-to-active-pdp-group">
343 <from uri="direct:add-all-to-active-pdp-group" />
347 message="Adding loop policies to PDP Group: ${exchangeProperty[loopObject].getName()}" />
349 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Add policies to PDP group')" />
351 <simple>${exchangeProperty[loopObject].createPoliciesPayloadPdpGroup()}
354 <setHeader headerName="CamelHttpMethod">
355 <constant>POST</constant>
357 <setHeader headerName="Content-Type">
358 <constant>application/json</constant>
360 <setHeader headerName="X-ONAP-RequestID">
361 <simple>${exchangeProperty[X-ONAP-RequestID]}
364 <setHeader headerName="X-ONAP-InvocationID">
365 <simple>${exchangeProperty[X-ONAP-InvocationID]}
368 <setHeader headerName="X-ONAP-PartnerName">
369 <simple>${exchangeProperty[X-ONAP-PartnerName]}
374 message="Endpoint to add policies to PDP Group: {{clamp.config.policy.url}}/policy/pap/v1/pdps"></log>
376 uri="{{clamp.config.policy.url}}/policy/pap/v1/pdps?throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&httpClient.connectTimeout=10000&authMethod=Basic&authUsername=test&authPassword=test" />
378 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Policies pushed to PDP Group successfully','INFO',${exchangeProperty[loopObject]})" />
379 <to uri="direct:reset-raise-http-exception-flag" />
381 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
384 <route id="remove-all-policy-from-active-pdp-group">
385 <from uri="direct:remove-all-policy-from-active-pdp-group" />
388 message="Removing policies from active PDP group for loop: ${exchangeProperty[loopObject].getName()}" />
390 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Removing policies PDP group')" />
392 <simple>${exchangeProperty[loopObject].listPolicyNamesPdpGroup()}
394 <setProperty propertyName="policyName">
395 <simple>${body}</simple>
398 <constant>null</constant>
400 <setHeader headerName="CamelHttpMethod">
401 <constant>DELETE</constant>
403 <setHeader headerName="X-ONAP-RequestID">
404 <simple>${exchangeProperty[X-ONAP-RequestID]}
407 <setHeader headerName="X-ONAP-InvocationID">
408 <simple>${exchangeProperty[X-ONAP-InvocationID]}
411 <setHeader headerName="X-ONAP-PartnerName">
412 <simple>${exchangeProperty[X-ONAP-PartnerName]}
417 message="Endpoint to delete policy from PDP Group: {{clamp.config.policy.url}}/pdps/policies/${exchangeProperty[policyName]}/versions/1.0.0"></log>
419 uri="{{clamp.config.policy.url}}/pdps/policies/${exchangeProperty[policyName]}/versions/1.0.0?bridgeEndpoint=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&httpClient.connectTimeout=10000&authUsername={{clamp.config.policy.userName}}&authPassword={{clamp.config.policy.password}}" />
421 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog(${exchangeProperty[policyName]}' Policy removed from PDP Group successfully','INFO',${exchangeProperty[loopObject]})" />
423 <to uri="direct:reset-raise-http-exception-flag" />
425 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
428 <route id="reset-raise-http-exception-flag">
429 <from uri="direct:reset-raise-http-exception-flag" />
430 <setProperty propertyName="raiseHttpExceptionFlag">
431 <simple resultType="java.lang.Boolean">true</simple>