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.getModelType()}</simple>
43 <setProperty propertyName="policyVersion">
44 <simple>1.0.0</simple>
47 <constant>null</constant>
49 <log loggingLevel="INFO"
50 message="Processing Micro Service Policy: ${exchangeProperty[policyName]} of type ${exchangeProperty[policyType]}" />
51 <to uri="direct:verify-one-policy" />
53 <log loggingLevel="INFO"
54 message="Processing all OPERATIONAL policies defined in loop ${exchangeProperty[loopObject].getName()}" />
56 <simple>${exchangeProperty[loopObject].getOperationalPolicies()}
58 <setProperty propertyName="policyName">
59 <simple>${body.getName()}</simple>
61 <setProperty propertyName="policyType">
62 <simple>onap.policies.controlloop.Operational</simple>
64 <setProperty propertyName="policyVersion">
67 <setProperty propertyName="operationalPolicy">
68 <simple>${body}</simple>
71 <constant>null</constant>
73 <log loggingLevel="INFO"
74 message="Processing Micro Service Policy: ${exchangeProperty[policyName]} of type ${exchangeProperty[policyType]}" />
75 <to uri="direct:verify-one-policy" />
76 <log loggingLevel="INFO"
77 message="Processing all GUARD policies defined in loop ${exchangeProperty[loopObject].getName()}" />
79 <simple>${exchangeProperty[operationalPolicy].createGuardPolicyPayloads().entrySet()}
81 <setProperty propertyName="policyName">
82 <simple>${body.getKey()}</simple>
84 <setProperty propertyName="policyType">
85 <simple>onap.policies.controlloop.Guard</simple>
87 <setProperty propertyName="policyVersion">
91 <constant>null</constant>
93 <log loggingLevel="INFO"
94 message="Processing Guard Policy: ${exchangeProperty[policyName]} of type ${exchangeProperty[policyType]}" />
95 <to uri="direct:verify-one-policy" />
98 <setProperty propertyName="policyState">
99 <simple> ${exchangeProperty[policyComponent].getState()}
102 <log loggingLevel="INFO"
103 message="Policy state set to: ${exchangeProperty[policyState].getStateName()}" />
105 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLogForComponent('Policy state set to: ${exchangeProperty[policyState].getStateName()}','INFO','POLICY',${exchangeProperty[loopObject]})" />
107 <route id="update-dcae-status-for-loop">
108 <from uri="direct:update-dcae-status-for-loop" />
109 <log loggingLevel="INFO"
110 message="Updating DCAE status for loop: ${exchangeProperty[loopObject].getName()}" />
111 <setProperty propertyName="dcaeComponent">
112 <simple>${exchangeProperty[loopObject].getComponent('DCAE')}</simple>
115 <simple>${exchangeProperty[loopObject].getDcaeDeploymentStatusUrl()}
118 <setProperty propertyName="raiseHttpExceptionFlag">
119 <simple resultType="java.lang.Boolean">false</simple>
121 <to uri="direct:get-dcae-deployment-status" />
123 <simple> ${header.CamelHttpResponseCode} == 200 </simple>
124 <convertBodyTo type="java.lang.String" />
125 <setProperty propertyName="dcaeResponse">
126 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
127 method="convertDcaeResponse(${body})" />
132 <setProperty propertyName="dcaeState">
133 <simple> ${exchangeProperty[dcaeComponent].computeState(*)}
136 <log loggingLevel="INFO"
137 message="DCAE state set to: ${exchangeProperty[dcaeState].getStateName()} - DCAE message: ${exchangeProperty[dcaeResponse].getError()}" />
139 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]})" />
142 <route id="direct:update-loop-state">
143 <from uri="direct:update-loop-state" />
144 <log loggingLevel="INFO"
145 message="Updating status for loop: ${exchangeProperty[loopObject].getName()}" />
148 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
149 'BLUEPRINT_DEPLOYED' and ${exchangeProperty['policyState'].getStateName()}
153 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'DESIGN')" />
156 <simple>${exchangeProperty['dcaeState'].getStateName()} == 'IN_ERROR' or
157 ${exchangeProperty['dcaeState'].getStateName()} ==
158 'MICROSERVICE_INSTALLATION_FAILED'
161 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'IN_ERROR')" />
164 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
165 'MICROSERVICE_UNINSTALLATION_FAILED' or
166 ${exchangeProperty['policyState'].getStateName()} == 'IN_ERROR'
169 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'IN_ERROR')" />
172 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
173 'MICROSERVICE_INSTALLED_SUCCESSFULLY' and
174 ${exchangeProperty['policyState'].getStateName()} == 'SENT_AND_DEPLOYED'
177 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'RUNNING')" />
180 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
181 'MICROSERVICE_INSTALLED_SUCCESSFULLY' and
182 ${exchangeProperty['policyState'].getStateName()} == 'SENT'
185 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'STOPPED')" />
188 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
189 'BLUEPRINT_DEPLOYED' or ${exchangeProperty['dcaeState'].getStateName()} ==
190 'MICROSERVICE_UNINSTALLED_SUCCESSFULLY' and
191 ${exchangeProperty['policyState'].getStateName()} == 'SENT_AND_DEPLOYED'
194 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'SUBMITTED')" />
197 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
198 'PROCESSING_MICROSERVICE_INSTALLATION' or
199 ${exchangeProperty['dcaeState'].getStateName()} ==
200 'PROCESSING_MICROSERVICE_UNINSTALLATION' and
201 ${exchangeProperty['policyState'].getStateName()} == 'SENT_AND_DEPLOYED'
204 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'WAITING')" />
207 <simple>${exchangeProperty['dcaeState'].getStateName()} ==
208 'MICROSERVICE_INSTALLED_SUCCESSFULLY' and
209 ${exchangeProperty['policyState'].getStateName()} != 'NOT_SENT'
212 uri="bean:org.onap.clamp.loop.LoopService?method=updateLoopState(${exchangeProperty[loopObject]},'DEPLOYED')" />
215 <log loggingLevel="INFO"
216 message="New loop state is: ${exchangeProperty[loopObject].getLastComputedState().toString()}" />
218 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('New loop state is: ${exchangeProperty[loopObject].getLastComputedState().toString()}','INFO',${exchangeProperty[loopObject]})" />