1 <routes xmlns="http://camel.apache.org/schema/spring">
3 <from uri="direct:load-loop" />
5 <simple>${header.loopName}</simple>
7 <setProperty propertyName="loopObject">
8 <method ref="org.onap.clamp.loop.LoopService" method="getLoop" />
12 <simple>${exchangeProperty[loopObject]} == null</simple>
13 <setHeader headerName="CamelHttpResponseCode">
14 <constant>404</constant>
16 <log loggingLevel="WARN" message="Loop not found in database: ${body}" />
20 <route id="update-policy-status-for-loop">
21 <from uri="direct:update-policy-status-for-loop" />
22 <setProperty propertyName="policyComponent">
23 <simple>${exchangeProperty[loopObject].getComponent('POLICY')}
26 <setProperty propertyName="policyFound">
27 <simple resultType="java.lang.Boolean">true</simple>
29 <setProperty propertyName="policyDeployed">
30 <simple resultType="java.lang.Boolean">true</simple>
32 <log loggingLevel="INFO"
33 message="Processing all MICRO-SERVICES policies defined in loop ${exchangeProperty[loopObject].getName()}" />
35 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
37 <setProperty propertyName="policyName">
38 <simple>${body.getName()}</simple>
40 <setProperty propertyName="policyType">
41 <simple>${body.getPolicyModel().getPolicyModelType()}</simple>
43 <setProperty propertyName="policyTypeVersion">
44 <simple>${body.getPolicyModel().getVersion()}</simple>
46 <setProperty propertyName="policyVersion">
47 <simple>1.0.0</simple>
50 <constant>null</constant>
52 <log loggingLevel="INFO"
53 message="Processing Micro Service Policy: ${exchangeProperty[policyName]} of type ${exchangeProperty[policyType]}" />
54 <to uri="direct:verify-one-policy" />
56 <log loggingLevel="INFO"
57 message="Processing all OPERATIONAL policies defined in loop ${exchangeProperty[loopObject].getName()}" />
59 <simple>${exchangeProperty[loopObject].getOperationalPolicies()}
61 <setProperty propertyName="policyName">
62 <simple>${body.getName()}</simple>
64 <setProperty propertyName="policyType">
65 <simple>${body.getPolicyModel().getPolicyModelType()}</simple>
67 <setProperty propertyName="policyTypeVersion">
68 <simple>${body.getPolicyModel().getVersion()}</simple>
72 <simple>${body.isLegacy()} == true</simple>
73 <setProperty propertyName="policyVersion">
78 <setProperty propertyName="policyVersion">
79 <simple>1.0.0</simple>
83 <setProperty propertyName="operationalPolicy">
84 <simple>${body}</simple>
87 <constant>null</constant>
89 <log loggingLevel="INFO"
90 message="Processing Micro Service Policy: ${exchangeProperty[policyName]} of type ${exchangeProperty[policyType]}" />
91 <to uri="direct:verify-one-policy" />
92 <log loggingLevel="INFO"
93 message="Processing all GUARD policies defined in loop ${exchangeProperty[loopObject].getName()}" />
95 <simple>${exchangeProperty[operationalPolicy].createGuardPolicyPayloads().entrySet()}
97 <setProperty propertyName="policyName">
98 <simple>${body.getKey()}</simple>
100 <setProperty propertyName="policyType">
101 <simple>onap.policies.controlloop.Guard</simple>
103 <setProperty propertyName="policyTypeVersion">
104 <simple>1.0.0</simple>
106 <setProperty propertyName="policyVersion">
110 <constant>null</constant>
112 <log loggingLevel="INFO"
113 message="Processing Guard Policy: ${exchangeProperty[policyName]} of type ${exchangeProperty[policyType]}" />
114 <to uri="direct:verify-one-policy" />
117 <setProperty propertyName="policyState">
118 <simple> ${exchangeProperty[policyComponent].getState()}
121 <log loggingLevel="INFO"
122 message="Policy state set to: ${exchangeProperty[policyState].getStateName()}" />
124 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLogForComponent('Policy state set to: ${exchangeProperty[policyState].getStateName()}','INFO','POLICY',${exchangeProperty[loopObject]})" />
126 <route id="update-dcae-status-for-loop">
127 <from uri="direct:update-dcae-status-for-loop" />
128 <log loggingLevel="INFO"
129 message="Updating DCAE status for loop: ${exchangeProperty[loopObject].getName()}" />
132 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getUniqueBlueprint()} == true
134 <setProperty propertyName="dcaeComponent">
135 <simple>${exchangeProperty[loopObject].getComponent('DCAE')}</simple>
138 <simple>${exchangeProperty[loopObject].getDcaeDeploymentStatusUrl()} != null
140 <setProperty propertyName="getStatusUrl">
141 <simple>${exchangeProperty[loopObject].getDcaeDeploymentStatusUrl()}</simple>
143 <setProperty propertyName="raiseHttpExceptionFlag">
144 <simple resultType="java.lang.Boolean">false</simple>
146 <to uri="direct:get-dcae-deployment-status" />
148 <simple> ${header.CamelHttpResponseCode} == 200 </simple>
149 <convertBodyTo type="java.lang.String" />
150 <setProperty propertyName="dcaeResponse">
151 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
152 method="convertDcaeResponse(${body})" />
156 <setProperty propertyName="dcaeState">
157 <simple> ${exchangeProperty[dcaeComponent].computeState(*)}
160 <log loggingLevel="INFO"
161 message="DCAE state set to: ${exchangeProperty[dcaeState].getStateName()} - DCAE message: ${exchangeProperty[dcaeResponse].getError()}" />
163 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLogForComponent('DCAE state set to: ${exchangeProperty[dcaeState].getStateName()} - message: ${exchangeProperty[dcaeResponse].getError()}','INFO','DCAE',${exchangeProperty[loopObject]})" />
166 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getUniqueBlueprint()} == false
169 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
171 <setProperty propertyName="microServicePolicy">
172 <simple>${body}</simple>
174 <setProperty propertyName="dcaeComponent">
175 <simple>${exchangeProperty[loopObject].getComponent('DCAE_' + ${exchangeProperty[microServicePolicy].getName()})}</simple>
178 <simple>${exchangeProperty[microServicePolicy].getDcaeDeploymentStatusUrl()} != null
180 <setProperty propertyName="getStatusUrl">
181 <simple>${exchangeProperty[microServicePolicy].getDcaeDeploymentStatusUrl()}</simple>
183 <setProperty propertyName="raiseHttpExceptionFlag">
184 <simple resultType="java.lang.Boolean">false</simple>
186 <to uri="direct:get-dcae-deployment-status" />
188 <simple> ${header.CamelHttpResponseCode} == 200 </simple>
189 <convertBodyTo type="java.lang.String" />
190 <setProperty propertyName="dcaeResponse">
191 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
192 method="convertDcaeResponse(${body})" />
196 <setProperty propertyName="dcaeState">
197 <simple> ${exchangeProperty[dcaeComponent].computeState(*)}
200 <log loggingLevel="INFO"
201 message="DCAE state set to: ${exchangeProperty[dcaeState].getStateName()} - DCAE message: ${exchangeProperty[dcaeResponse].getError()}" />
203 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLogForComponent('DCAE state set to: ${exchangeProperty[dcaeState].getStateName()} - message: ${exchangeProperty[dcaeResponse].getError()}','INFO','DCAE',${exchangeProperty[microServicePolicy]})" />
208 <route id="direct:update-loop-state">
209 <from uri="direct:update-loop-state" />
210 <log loggingLevel="INFO"
211 message="Updating status for loop: ${exchangeProperty[loopObject].getName()}" />
214 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
215 'BLUEPRINT_DEPLOYED' and ${exchangeProperty['policyState'].getStateName()}
219 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'DESIGN')" />
222 <simple>${exchangeProperty['dcaeState'].getStateName()} == 'IN_ERROR' or
223 ${exchangeProperty['dcaeState'].getStateName()} ==
224 'MICROSERVICE_INSTALLATION_FAILED'
227 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'IN_ERROR')" />
230 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
231 'MICROSERVICE_UNINSTALLATION_FAILED' or
232 ${exchangeProperty['policyState'].getStateName()} == 'IN_ERROR'
235 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'IN_ERROR')" />
238 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
239 'MICROSERVICE_INSTALLED_SUCCESSFULLY' and
240 ${exchangeProperty['policyState'].getStateName()} == 'SENT_AND_DEPLOYED'
243 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'RUNNING')" />
246 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
247 'MICROSERVICE_INSTALLED_SUCCESSFULLY' and
248 ${exchangeProperty['policyState'].getStateName()} == 'SENT'
251 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'STOPPED')" />
254 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
255 'BLUEPRINT_DEPLOYED' or ${exchangeProperty['dcaeState'].getStateName()} ==
256 'MICROSERVICE_UNINSTALLED_SUCCESSFULLY' and
257 ${exchangeProperty['policyState'].getStateName()} == 'SENT_AND_DEPLOYED'
260 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'SUBMITTED')" />
263 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
264 'PROCESSING_MICROSERVICE_INSTALLATION' or
265 ${exchangeProperty['dcaeState'].getStateName()} ==
266 'PROCESSING_MICROSERVICE_UNINSTALLATION' and
267 ${exchangeProperty['policyState'].getStateName()} == 'SENT_AND_DEPLOYED'
270 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'WAITING')" />
273 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
274 'MICROSERVICE_INSTALLED_SUCCESSFULLY' and
275 ${exchangeProperty['policyState'].getStateName()} != 'NOT_SENT'
278 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'DEPLOYED')" />
281 <log loggingLevel="INFO"
282 message="New loop state is: ${exchangeProperty[loopObject].getLastComputedState().toString()}" />
284 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('New loop state is: ${exchangeProperty[loopObject].getLastComputedState().toString()}','INFO',${exchangeProperty[loopObject]})" />