2 <routes xmlns="http://camel.apache.org/schema/spring">
3 <route id="get-policy">
4 <from uri="direct:get-policy" />
8 message="Getting Policy: ${exchangeProperty[policyName]}" />
10 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Get Policy')" />
11 <setHeader headerName="CamelHttpMethod">
12 <constant>GET</constant>
14 <setHeader headerName="X-ONAP-RequestID">
15 <simple>${exchangeProperty[X-ONAP-RequestID]}
18 <setHeader headerName="X-ONAP-InvocationID">
19 <simple>${exchangeProperty[X-ONAP-InvocationID]}
22 <setHeader headerName="X-ONAP-PartnerName">
23 <simple>${exchangeProperty[X-ONAP-PartnerName]}
28 message="Endpoint to get policy: {{clamp.config.policy.api.url}}/policy/api/v1/policytypes/${exchangeProperty[policyType]}/versions/1.0.0/policies/${exchangeProperty[policyName]}/versions/1.0.0"></log>
30 uri="{{clamp.config.policy.api.url}}/policy/api/v1/policytypes/${exchangeProperty[policyType]}/versions/1.0.0/policies/${exchangeProperty[policyName]}/versions/1.0.0?bridgeEndpoint=true&useSystemProperties=true&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authMethod=Basic&authUsername={{clamp.config.policy.api.userName}}&authPassword={{clamp.config.policy.api.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=20000&authenticationPreemptive=true&connectionClose=true" />
32 <to uri="direct:reset-raise-http-exception-flag" />
34 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
35 <setProperty propertyName="logMessage">
36 <simple>${exchangeProperty[policyName]} GET
40 <to uri="direct:dump-loop-log-http-response" />
45 <route id="get-deployment-policy">
46 <from uri="direct:get-deployment-policy" />
50 message="Getting the policy deployment in PDP: ${exchangeProperty[policyName]}" />
52 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Getting the policy deployment in PDP')" />
53 <setHeader headerName="CamelHttpMethod">
54 <constant>GET</constant>
56 <setHeader headerName="X-ONAP-RequestID">
57 <simple>${exchangeProperty[X-ONAP-RequestID]}
60 <setHeader headerName="X-ONAP-InvocationID">
61 <simple>${exchangeProperty[X-ONAP-InvocationID]}
64 <setHeader headerName="X-ONAP-PartnerName">
65 <simple>${exchangeProperty[X-ONAP-PartnerName]}
70 message="Endpoint to get policy deployment status: {{clamp.config.policy.api.url}}/policy/api/v1/policytypes/${exchangeProperty[policyType]}/versions/1.0.0/policies/${exchangeProperty[policyName]}/versions/deployed"></log>
72 uri="{{clamp.config.policy.api.url}}/policy/api/v1/policytypes/${exchangeProperty[policyType]}/versions/1.0.0/policies/${exchangeProperty[policyName]}/versions/deployed?bridgeEndpoint=true&useSystemProperties=true&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authMethod=Basic&authUsername={{clamp.config.policy.api.userName}}&authPassword={{clamp.config.policy.api.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=20000&authenticationPreemptive=true&connectionClose=true" />
74 <to uri="direct:reset-raise-http-exception-flag" />
76 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
77 <setProperty propertyName="logMessage">
78 <simple>${exchangeProperty[policyName]} GET Policy deployment
82 <to uri="direct:dump-loop-log-http-response" />
86 <route id="create-micro-service-policy">
87 <from uri="direct:create-micro-service-policy" />
91 message="Creating Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
93 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Create Micro Service Policy')" />
95 <simple>${exchangeProperty[microServicePolicy].createPolicyPayload()}
98 <setHeader headerName="CamelHttpMethod">
99 <constant>POST</constant>
101 <setHeader headerName="Content-Type">
102 <constant>application/json</constant>
104 <setHeader headerName="X-ONAP-RequestID">
105 <simple>${exchangeProperty[X-ONAP-RequestID]}
108 <setHeader headerName="X-ONAP-InvocationID">
109 <simple>${exchangeProperty[X-ONAP-InvocationID]}
112 <setHeader headerName="X-ONAP-PartnerName">
113 <simple>${exchangeProperty[X-ONAP-PartnerName]}
118 message="Endpoint to create microservice policy: {{clamp.config.policy.api.url}}/policy/api/v1/policytypes/${exchangeProperty[microServicePolicy].getModelType()}/versions/1.0.0/policies"></log>
120 uri="{{clamp.config.policy.api.url}}/policy/api/v1/policytypes/${exchangeProperty[microServicePolicy].getModelType()}/versions/1.0.0/policies?bridgeEndpoint=true&useSystemProperties=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authUsername={{clamp.config.policy.api.userName}}&authPassword={{clamp.config.policy.api.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=20000&authenticationPreemptive=true&connectionClose=true" />
122 <to uri="direct:reset-raise-http-exception-flag" />
124 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
125 <setProperty propertyName="logMessage">
126 <simple>${exchangeProperty[microServicePolicy].getName()} creation
130 <to uri="direct:dump-loop-log-http-response" />
135 <route id="delete-micro-service-policy">
136 <from uri="direct:delete-micro-service-policy" />
140 message="Deleting Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
142 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Delete Micro Service Policy')" />
144 <constant>null</constant>
146 <setHeader headerName="CamelHttpMethod">
147 <constant>DELETE</constant>
149 <setHeader headerName="X-ONAP-RequestID">
150 <simple>${exchangeProperty[X-ONAP-RequestID]}
153 <setHeader headerName="X-ONAP-InvocationID">
154 <simple>${exchangeProperty[X-ONAP-InvocationID]}
157 <setHeader headerName="X-ONAP-PartnerName">
158 <simple>${exchangeProperty[X-ONAP-PartnerName]}
163 message="Endpoint to delete microservice policy: {{clamp.config.policy.api.url}}/policy/api/v1/policytypes/${exchangeProperty[microServicePolicy].getModelType()}/versions/1.0.0/policies/${exchangeProperty[microServicePolicy].getName()}/versions/1.0.0"></log>
165 uri="{{clamp.config.policy.api.url}}/policy/api/v1/policytypes/${exchangeProperty[microServicePolicy].getModelType()}/versions/1.0.0/policies/${exchangeProperty[microServicePolicy].getName()}/versions/1.0.0?bridgeEndpoint=true&useSystemProperties=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&deleteWithBody=false&mapHttpMessageBody=false&mapHttpMessageFormUrlEncodedBody=false&authUsername={{clamp.config.policy.api.userName}}&authPassword={{clamp.config.policy.api.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=20000&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>${exchangeProperty[microServicePolicy].getName()} removal
176 <to uri="direct:dump-loop-log-http-response" />
181 <route id="create-operational-policy">
182 <from uri="direct:create-operational-policy" />
186 message="Creating Operational Policy: ${exchangeProperty[operationalPolicy].getName()}" />
188 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Create Operational Policy')" />
190 <simple>${exchangeProperty[operationalPolicy].createPolicyPayload()}
193 <setHeader headerName="CamelHttpMethod">
194 <constant>POST</constant>
196 <setHeader headerName="Content-Type">
197 <constant>application/json</constant>
199 <setHeader headerName="X-ONAP-RequestID">
200 <simple>${exchangeProperty[X-ONAP-RequestID]}
203 <setHeader headerName="X-ONAP-InvocationID">
204 <simple>${exchangeProperty[X-ONAP-InvocationID]}
207 <setHeader headerName="X-ONAP-PartnerName">
208 <simple>${exchangeProperty[X-ONAP-PartnerName]}
213 message="Endpoint to create operational policy: {{clamp.config.policy.api.url}}/policy/api/v1/policytypes/onap.policies.controlloop.Operational/versions/1.0.0/policies"></log>
215 uri="{{clamp.config.policy.api.url}}/policy/api/v1/policytypes/onap.policies.controlloop.Operational/versions/1.0.0/policies?bridgeEndpoint=true&useSystemProperties=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authUsername={{clamp.config.policy.api.userName}}&authPassword={{clamp.config.policy.api.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=20000&authenticationPreemptive=true&connectionClose=true" />
217 <to uri="direct:reset-raise-http-exception-flag" />
219 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
220 <setProperty propertyName="logMessage">
221 <simple>${exchangeProperty[operationalPolicy].getName()} creation
225 <to uri="direct:dump-loop-log-http-response" />
230 <route id="delete-operational-policy">
231 <from uri="direct:delete-operational-policy" />
235 message="Deleting Operational Policy: ${exchangeProperty[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="X-ONAP-RequestID">
245 <simple>${exchangeProperty[X-ONAP-RequestID]}
248 <setHeader headerName="X-ONAP-InvocationID">
249 <simple>${exchangeProperty[X-ONAP-InvocationID]}
252 <setHeader headerName="X-ONAP-PartnerName">
253 <simple>${exchangeProperty[X-ONAP-PartnerName]}
258 message="Endpoint to delete operational policy: {{clamp.config.policy.api.url}}/policy/api/v1/policytypes/onap.policies.controlloop.Operational/versions/1.0.0/policies/${exchangeProperty[operationalPolicy].getName()}/versions/1"></log>
260 uri="{{clamp.config.policy.api.url}}/policy/api/v1/policytypes/onap.policies.controlloop.Operational/versions/1.0.0/policies/${exchangeProperty[operationalPolicy].getName()}/versions/1?bridgeEndpoint=true&useSystemProperties=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&deleteWithBody=false&mapHttpMessageBody=false&mapHttpMessageFormUrlEncodedBody=false&authUsername={{clamp.config.policy.api.userName}}&authPassword={{clamp.config.policy.api.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=20000&authenticationPreemptive=true&connectionClose=true" />
262 <to uri="direct:reset-raise-http-exception-flag" />
264 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
265 <setProperty propertyName="logMessage">
266 <simple>${exchangeProperty[operationalPolicy].getName()} removal
270 <to uri="direct:dump-loop-log-http-response" />
275 <route id="create-guard-policy">
276 <from uri="direct:create-guard-policy" />
280 message="Creating Guard Policy: ${exchangeProperty[guardPolicy].getKey()}" />
282 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Create Guard Policy')" />
284 <simple>${exchangeProperty[guardPolicy].getValue()}
287 <setHeader headerName="CamelHttpMethod">
288 <constant>POST</constant>
290 <setHeader headerName="Content-Type">
291 <constant>application/json</constant>
293 <setHeader headerName="X-ONAP-RequestID">
294 <simple>${exchangeProperty[X-ONAP-RequestID]}
297 <setHeader headerName="X-ONAP-InvocationID">
298 <simple>${exchangeProperty[X-ONAP-InvocationID]}
301 <setHeader headerName="X-ONAP-PartnerName">
302 <simple>${exchangeProperty[X-ONAP-PartnerName]}
307 message="Endpoint to create guard policy: {{clamp.config.policy.api.url}}/policy/api/v1/policytypes/onap.policies.controlloop.Guard/versions/1.0.0/policies"></log>
309 uri="{{clamp.config.policy.api.url}}/policy/api/v1/policytypes/onap.policies.controlloop.Guard/versions/1.0.0/policies?bridgeEndpoint=true&useSystemProperties=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authUsername={{clamp.config.policy.api.userName}}&authPassword={{clamp.config.policy.api.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=20000&authenticationPreemptive=true&connectionClose=true" />
311 <to uri="direct:reset-raise-http-exception-flag" />
313 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
314 <setProperty propertyName="logMessage">
315 <simple>${exchangeProperty[guardPolicy].getKey()} creation status
318 <to uri="direct:dump-loop-log-http-response" />
323 <route id="delete-guard-policy">
324 <from uri="direct:delete-guard-policy" />
328 message="Deleting Guard Policy: ${exchangeProperty[guardPolicy].getKey()}" />
330 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Delete Guard Policy')" />
332 <constant>null</constant>
334 <setHeader headerName="CamelHttpMethod">
335 <constant>DELETE</constant>
337 <setHeader headerName="X-ONAP-RequestID">
338 <simple>${exchangeProperty[X-ONAP-RequestID]}
341 <setHeader headerName="X-ONAP-InvocationID">
342 <simple>${exchangeProperty[X-ONAP-InvocationID]}
345 <setHeader headerName="X-ONAP-PartnerName">
346 <simple>${exchangeProperty[X-ONAP-PartnerName]}
351 message="Endpoint to delete guard policy: {{clamp.config.policy.api.url}}/policy/api/v1/policytypes/onap.policies.controlloop.Guard/versions/1.0.0/policies/${exchangeProperty[guardPolicy].getKey()}/versions/1"></log>
353 uri="{{clamp.config.policy.api.url}}/policy/api/v1/policytypes/onap.policies.controlloop.Guard/versions/1.0.0/policies/${exchangeProperty[guardPolicy].getKey()}/versions/1?bridgeEndpoint=true&useSystemProperties=true&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&deleteWithBody=false&mapHttpMessageBody=false&mapHttpMessageFormUrlEncodedBody=false&authUsername={{clamp.config.policy.api.userName}}&authPassword={{clamp.config.policy.api.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=20000&authenticationPreemptive=true&connectionClose=true" />
356 <to uri="direct:reset-raise-http-exception-flag" />
358 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
359 <setProperty propertyName="logMessage">
360 <simple>${exchangeProperty[guardPolicy].getKey()} removal status
363 <to uri="direct:dump-loop-log-http-response" />
368 <route id="add-all-to-active-pdp-group">
369 <from uri="direct:add-all-to-active-pdp-group" />
373 message="Adding loop policies to PDP Group: ${exchangeProperty[loopObject].getName()}" />
375 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Add policies to PDP group')" />
377 <simple>${exchangeProperty[loopObject].getComponent("POLICY").createPoliciesPayloadPdpGroup(exchangeProperty[loopObject])}
380 <setHeader headerName="CamelHttpMethod">
381 <constant>POST</constant>
383 <setHeader headerName="Content-Type">
384 <constant>application/json</constant>
386 <setHeader headerName="X-ONAP-RequestID">
387 <simple>${exchangeProperty[X-ONAP-RequestID]}
390 <setHeader headerName="X-ONAP-InvocationID">
391 <simple>${exchangeProperty[X-ONAP-InvocationID]}
394 <setHeader headerName="X-ONAP-PartnerName">
395 <simple>${exchangeProperty[X-ONAP-PartnerName]}
400 message="Endpoint to add policies to PDP Group: {{clamp.config.policy.pap.url}}/policy/pap/v1/pdps/policies"></log>
402 uri="{{clamp.config.policy.pap.url}}/policy/pap/v1/pdps/policies?bridgeEndpoint=true&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&useSystemProperties=true&authUsername={{clamp.config.policy.pap.userName}}&authPassword={{clamp.config.policy.pap.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=20000&authenticationPreemptive=true&connectionClose=true" />
405 <to uri="direct:reset-raise-http-exception-flag" />
407 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />
408 <setProperty propertyName="logMessage">
409 <simple>PDP Group push ALL status</simple>
411 <to uri="direct:dump-loop-log-http-response" />
416 <route id="remove-all-policy-from-active-pdp-group">
417 <from uri="direct:remove-all-policy-from-active-pdp-group" />
421 message="Removing policies from active PDP group for loop: ${exchangeProperty[loopObject].getName()}" />
423 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('Policy', 'Removing policies PDP group')" />
425 <simple>${exchangeProperty[loopObject].getComponent("POLICY").listPolicyNamesPdpGroup(exchangeProperty[loopObject])}
427 <setProperty propertyName="policyName">
428 <simple>${body}</simple>
431 <constant>null</constant>
433 <setHeader headerName="CamelHttpMethod">
434 <constant>DELETE</constant>
436 <setHeader headerName="X-ONAP-RequestID">
437 <simple>${exchangeProperty[X-ONAP-RequestID]}
440 <setHeader headerName="X-ONAP-InvocationID">
441 <simple>${exchangeProperty[X-ONAP-InvocationID]}
444 <setHeader headerName="X-ONAP-PartnerName">
445 <simple>${exchangeProperty[X-ONAP-PartnerName]}
450 message="Endpoint to delete policy from PDP Group: {{clamp.config.policy.pap.url}}/pdps/policies/${exchangeProperty[policyName]}/versions/1.0.0"></log>
452 uri="{{clamp.config.policy.pap.url}}/policy/pap/v1/pdps/policies/${exchangeProperty[policyName]}/versions/1.0.0?bridgeEndpoint=true&useSystemProperties=true&mapHttpMessageHeaders=false&throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&authUsername={{clamp.config.policy.pap.userName}}&authPassword={{clamp.config.policy.pap.password}}&connectionTimeToLive=5000&httpClient.connectTimeout=10000&httpClient.socketTimeout=20000&authenticationPreemptive=true&connectionClose=true" />
453 <setProperty propertyName="logMessage">
454 <simple>${exchangeProperty[policyName]} PDP Group removal status
457 <to uri="direct:dump-loop-log-http-response" />
460 <exception>java.lang.Exception</exception>
462 <constant>false</constant>
464 <setProperty propertyName="logMessage">
465 <simple>PDP Group removal, Error reported: ${exception}</simple>
467 <to uri="direct:dump-loop-log-http-response" />
470 <to uri="direct:reset-raise-http-exception-flag" />
472 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()" />