src/main/resources/clds/camel/routes/dcae-flows.xml

   1 <routes xmlns="http://camel.apache.org/schema/spring">
   2     <route id="deploy-loop">
   3         <from uri="direct:deploy-loop"/>
   4         <choice>
   5             <when>
   6                 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getUniqueBlueprint()} == true
   7                 </simple>
   8                 <to uri="direct:deploy-loop-single-blueprint"/>
   9             </when>
  10             <when>
  11                 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getUniqueBlueprint()} == false
  12                 </simple>
  13                 <to uri="direct:deploy-loop-multi-blueprint"/>
  14             </when>
  15         </choice>
  16     </route>
  17     <route id="deploy-loop-multi-blueprint">
  18         <from uri="direct:deploy-loop-multi-blueprint"/>
  19         <doTry>
  20             <log loggingLevel="INFO"
  21                  message="Deploying the blueprints for loop: ${exchangeProperty[loopObject].getName()}"/>
  22             <to
  23                     uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Deploying the loop with multiple blueprints')"/>
  24             <split>
  25                 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
  26                 </simple>
  27                 <setProperty propertyName="microServicePolicy">
  28                     <simple>${body}</simple>
  29                 </setProperty>
  30                 <log
  31                         loggingLevel="INFO"
  32                         message="Processing Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}"/>
  33                 <setProperty propertyName="raiseHttpExceptionFlag">
  34                     <simple resultType="java.lang.Boolean">false</simple>
  35                 </setProperty>
  36                 <setBody>
  37                     <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
  38                             method="getDeployPayload(${exchangeProperty[loopObject]},${exchangeProperty[microServicePolicy]})"/>
  39                 </setBody>
  40                 <setProperty propertyName="dcaeDeploymentId">
  41                     <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
  42                             method="generateDeploymentId()"/>
  43                 </setProperty>
  44                 <setHeader headerName="CamelHttpMethod">
  45                     <constant>PUT</constant>
  46                 </setHeader>
  47                 <setHeader headerName="Content-Type">
  48                     <constant>application/json</constant>
  49                 </setHeader>
  50                 <setHeader headerName="X-ONAP-RequestID">
  51                     <simple>${exchangeProperty[X-ONAP-RequestID]}
  52                     </simple>
  53                 </setHeader>
  54                 <setHeader headerName="X-ONAP-InvocationID">
  55                     <simple>${exchangeProperty[X-ONAP-InvocationID]}
  56                     </simple>
  57                 </setHeader>
  58                 <setHeader headerName="X-ONAP-PartnerName">
  59                     <simple>${exchangeProperty[X-ONAP-PartnerName]}
  60                     </simple>
  61                 </setHeader>
  62                 <log loggingLevel="INFO"
  63                      message="Endpoint to deploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}"></log>
  64                 <toD
  65                         uri="{{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}?bridgeEndpoint=true&amp;useSystemProperties=true&amp;mapHttpMessageHeaders=false&amp;throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&amp;authUsername={{clamp.config.dcae.deployment.userName}}&amp;authPassword={{clamp.config.dcae.deployment.password}}&amp;httpClient.connectTimeout=10000&amp;httpClient.socketTimeout=300000&amp;authenticationPreemptive=true&amp;connectionClose=true"/>
  66                 <convertBodyTo type="java.lang.String"/>
  67                 <setProperty propertyName="dcaeResponse">
  68                     <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
  69                             method="convertDcaeResponse(${body})"/>
  70                 </setProperty>
  71                 <setProperty propertyName="dcaeStatusUrl">
  72                     <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
  73                             method="getStatusUrl(${exchangeProperty[dcaeResponse]})"/>
  74                 </setProperty>
  75                 <to
  76                         uri="bean:org.onap.clamp.policy.microservice.MicroServicePolicyService?method=updateDcaeDeploymentFields(${exchangeProperty[microServicePolicy]},${exchangeProperty[dcaeDeploymentId]},${exchangeProperty[dcaeStatusUrl]})"/>
  77                 <to
  78                         uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLogForComponent('Deploy for the micro service: ${exchangeProperty[microServicePolicy].getName()} - ${header.CamelHttpResponseCode} : ${header.CamelHttpResponseText}','INFO','DCAE',${exchangeProperty[loopObject]})"/>
  79             </split>
  80             <doCatch>
  81                 <exception>java.lang.Exception</exception>
  82                 <handled>
  83                     <constant>false</constant>
  84                 </handled>
  85                 <setProperty propertyName="logMessage">
  86                     <simple>DEPLOY micro service failed
  87                         (MicroService name:${exchangeProperty[microServicePolicy].getName()}),
  88                         Dep-id:${exchangeProperty[dcaeDeploymentId]},
  89                         StatusUrl:${exchangeProperty[dcaeStatusUrl]})
  90                     </simple>
  91                 </setProperty>
  92                 <setProperty propertyName="logComponent">
  93                     <simple>DCAE</simple>
  94                 </setProperty>
  95                 <to uri="direct:dump-loop-log-http-response"/>
  96             </doCatch>
  97             <doFinally>
  98                 <to uri="direct:reset-raise-http-exception-flag"/>
  99                 <to
 100                         uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()"/>
 101             </doFinally>
 102         </doTry>
 103     </route>
 104     <route id="deploy-loop-single-blueprint">
 105         <from uri="direct:deploy-loop-single-blueprint"/>
 106         <doTry>
 107             <log loggingLevel="INFO"
 108                  message="Deploying the loop: ${exchangeProperty[loopObject].getName()}"/>
 109             <to
 110                     uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Deploying the loop')"/>
 111             <setBody>
 112                 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
 113                         method="getDeployPayload(${exchangeProperty[loopObject]})"/>
 114             </setBody>
 115             <setProperty propertyName="dcaeDeploymentId">
 116                 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
 117                         method="generateDeploymentId()"/>
 118             </setProperty>
 119             <setHeader headerName="CamelHttpMethod">
 120                 <constant>PUT</constant>
 121             </setHeader>
 122             <setHeader headerName="Content-Type">
 123                 <constant>application/json</constant>
 124             </setHeader>
 125             <setHeader headerName="X-ONAP-RequestID">
 126                 <simple>${exchangeProperty[X-ONAP-RequestID]}
 127                 </simple>
 128             </setHeader>
 129             <setHeader headerName="X-ONAP-InvocationID">
 130                 <simple>${exchangeProperty[X-ONAP-InvocationID]}
 131                 </simple>
 132             </setHeader>
 133             <setHeader headerName="X-ONAP-PartnerName">
 134                 <simple>${exchangeProperty[X-ONAP-PartnerName]}
 135                 </simple>
 136             </setHeader>
 137             <log loggingLevel="INFO"
 138                  message="Endpoint to deploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}"></log>
 139             <toD
 140                     uri="{{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[dcaeDeploymentId]}?bridgeEndpoint=true&amp;useSystemProperties=true&amp;mapHttpMessageHeaders=false&amp;throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&amp;authUsername={{clamp.config.dcae.deployment.userName}}&amp;authPassword={{clamp.config.dcae.deployment.password}}&amp;httpClient.connectTimeout=10000&amp;httpClient.socketTimeout=300000&amp;authenticationPreemptive=true&amp;connectionClose=true"/>
 141             <convertBodyTo type="java.lang.String"/>
 142             <setProperty propertyName="dcaeResponse">
 143                 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
 144                         method="convertDcaeResponse(${body})"/>
 145             </setProperty>
 146
 147
 148             <setProperty propertyName="dcaeStatusUrl">
 149                 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
 150                         method="getStatusUrl(${exchangeProperty[dcaeResponse]})"/>
 151             </setProperty>
 152             <to
 153                     uri="bean:org.onap.clamp.loop.LoopService?method=updateDcaeDeploymentFields(${exchangeProperty[loopObject]},${exchangeProperty[dcaeDeploymentId]},${exchangeProperty[dcaeStatusUrl]})"/>
 154             <doFinally>
 155                 <to uri="direct:reset-raise-http-exception-flag"/>
 156                 <to
 157                         uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()"/>
 158                 <setProperty propertyName="logMessage">
 159                     <simple>DEPLOY loop status
 160                         (Dep-id:${exchangeProperty[dcaeDeploymentId]},
 161                         StatusUrl:${exchangeProperty[dcaeStatusUrl]})
 162                     </simple>
 163                 </setProperty>
 164                 <setProperty propertyName="logComponent">
 165                     <simple>DCAE</simple>
 166                 </setProperty>
 167                 <to uri="direct:dump-loop-log-http-response"/>
 168             </doFinally>
 169         </doTry>
 170     </route>
 171     <route id="undeploy-loop">
 172         <from uri="direct:undeploy-loop"/>
 173         <choice>
 174             <when>
 175                 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getUniqueBlueprint()} == true
 176                 </simple>
 177                 <to uri="direct:undeploy-loop-single-blueprint"/>
 178             </when>
 179             <when>
 180                 <simple>${exchangeProperty['loopObject'].getLoopTemplate().getUniqueBlueprint()} == false
 181                 </simple>
 182                 <to uri="direct:undeploy-loop-multi-blueprint"/>
 183             </when>
 184         </choice>
 185     </route>
 186     <route id="undeploy-loop-multi-blueprint">
 187         <from uri="direct:undeploy-loop-multi-blueprint"/>
 188         <doTry>
 189             <log loggingLevel="INFO"
 190                  message="Undeploying the blueprints for loop: ${exchangeProperty[loopObject].getName()}"/>
 191             <to
 192                     uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Undeploying the loop with multiple blueprints')"/>
 193             <split>
 194                 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
 195                 </simple>
 196                 <setProperty propertyName="microServicePolicy">
 197                     <simple>${body}</simple>
 198                 </setProperty>
 199                 <log
 200                         loggingLevel="INFO"
 201                         message="Processing Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}"/>
 202                 <choice>
 203                     <when>
 204                         <simple>${exchangeProperty[microServicePolicy].getDcaeDeploymentId()} != null
 205                         </simple>
 206                         <setBody>
 207                             <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
 208                                     method="getUndeployPayload(${exchangeProperty[microServicePolicy]})"/>
 209                         </setBody>
 210                         <setHeader headerName="CamelHttpMethod">
 211                             <constant>DELETE</constant>
 212                         </setHeader>
 213                         <setHeader headerName="Content-Type">
 214                             <constant>application/json</constant>
 215                         </setHeader>
 216                         <setHeader headerName="X-ONAP-RequestID">
 217                             <simple>${exchangeProperty[X-ONAP-RequestID]}
 218                             </simple>
 219                         </setHeader>
 220                         <setHeader headerName="X-ONAP-InvocationID">
 221                             <simple>${exchangeProperty[X-ONAP-InvocationID]}
 222                             </simple>
 223                         </setHeader>
 224                         <setHeader headerName="X-ONAP-PartnerName">
 225                             <simple>${exchangeProperty[X-ONAP-PartnerName]}
 226                             </simple>
 227                         </setHeader>
 228                         <log loggingLevel="INFO"
 229                              message="Endpoint to undeploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[microServicePolicy].getDcaeDeploymentId()}"></log>
 230                         <toD
 231                                 uri="{{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[microServicePolicy].getDcaeDeploymentId()}?bridgeEndpoint=true&amp;useSystemProperties=true&amp;mapHttpMessageHeaders=false&amp;throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&amp;authUsername={{clamp.config.dcae.deployment.userName}}&amp;authPassword={{clamp.config.dcae.deployment.password}}&amp;httpClient.connectTimeout=10000&amp;httpClient.socketTimeout=300000&amp;authenticationPreemptive=true&amp;connectionClose=true"/>
 232                         <convertBodyTo type="java.lang.String"/>
 233                         <setProperty propertyName="dcaeResponse">
 234                             <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
 235                                     method="convertDcaeResponse(${body})"/>
 236                         </setProperty>
 237                         <setProperty propertyName="dcaeStatusUrl">
 238                             <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
 239                                     method="getStatusUrl(${exchangeProperty[dcaeResponse]})"/>
 240                         </setProperty>
 241                         <to
 242                                 uri="bean:org.onap.clamp.policy.microservice.MicroServicePolicyService?method=updateDcaeDeploymentFields(${exchangeProperty[microServicePolicy]},null,${exchangeProperty[dcaeStatusUrl]})"/>
 243                         <to
 244                                 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLogForComponent('Undeploy for the micro service: ${exchangeProperty[microServicePolicy].getName()} - ${header.CamelHttpResponseCode} : ${header.CamelHttpResponseText}','INFO','DCAE',${exchangeProperty[loopObject]})"/>
 245                     </when>
 246                     <otherwise>
 247                         <log loggingLevel="WARNING"
 248                              message="Cannot Undeploy for the micro service: ${exchangeProperty[microServicePolicy].getName()}, the Deployment ID does not exist !"/>
 249                         <to
 250                                 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLogForComponent('Cannot Undeploy for the micro service: ${exchangeProperty[microServicePolicy].getName()}, the Deployment ID does not exist !','WARNING','DCAE',${exchangeProperty[loopObject]})"/>
 251                     </otherwise>
 252                 </choice>
 253             </split>
 254             <doCatch>
 255                 <exception>java.lang.Exception</exception>
 256                 <handled>
 257                     <constant>false</constant>
 258                 </handled>
 259                 <setProperty propertyName="logMessage">
 260                     <simple>UNDEPLOY micro service failed
 261                         (MicroService name:${exchangeProperty[microServicePolicy].getName()})
 262                     </simple>
 263                 </setProperty>
 264                 <setProperty propertyName="logComponent">
 265                     <simple>DCAE</simple>
 266                 </setProperty>
 267                 <to uri="direct:dump-loop-log-http-response"/>
 268             </doCatch>
 269             <doFinally>
 270                 <to uri="direct:reset-raise-http-exception-flag"/>
 271                 <to
 272                         uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()"/>
 273             </doFinally>
 274         </doTry>
 275     </route>
 276     <route id="undeploy-loop-single-blueprint">
 277         <from uri="direct:undeploy-loop-single-blueprint"/>
 278         <log loggingLevel="INFO"
 279              message="Undeploying the loop: ${exchangeProperty[loopObject].getName()} : ${exchangeProperty[loopObject].getDcaeDeploymentId()}"/>
 280         <to
 281                 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Undeploying the loop')"/>
 282         <choice>
 283             <when>
 284                 <simple>${exchangeProperty[loopObject].getDcaeDeploymentId()}
 285                     != null
 286                 </simple>
 287                 <doTry>
 288                     <setBody>
 289                         <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
 290                                 method="getUndeployPayload(${exchangeProperty[loopObject]})"/>
 291                     </setBody>
 292                     <setHeader headerName="CamelHttpMethod">
 293                         <constant>DELETE</constant>
 294                     </setHeader>
 295                     <setHeader headerName="Content-Type">
 296                         <constant>application/json</constant>
 297                     </setHeader>
 298
 299                     <setHeader headerName="X-ONAP-RequestID">
 300                         <simple>${exchangeProperty[X-ONAP-RequestID]}
 301                         </simple>
 302                     </setHeader>
 303                     <setHeader headerName="X-ONAP-InvocationID">
 304                         <simple>${exchangeProperty[X-ONAP-InvocationID]}
 305                         </simple>
 306                     </setHeader>
 307                     <setHeader headerName="X-ONAP-PartnerName">
 308                         <simple>${exchangeProperty[X-ONAP-PartnerName]}
 309                         </simple>
 310                     </setHeader>
 311                     <log loggingLevel="INFO"
 312                          message="Endpoint to undeploy loop: {{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[loopObject].getDcaeDeploymentId()}"></log>
 313                     <toD
 314                             uri="{{clamp.config.dcae.deployment.url}}/dcae-deployments/${exchangeProperty[loopObject].getDcaeDeploymentId()}?bridgeEndpoint=true&amp;useSystemProperties=true&amp;mapHttpMessageHeaders=false&amp;throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&amp;authUsername={{clamp.config.dcae.deployment.userName}}&amp;authPassword={{clamp.config.dcae.deployment.password}}&amp;httpClient.connectTimeout=10000&amp;httpClient.socketTimeout=300000&amp;authenticationPreemptive=true&amp;connectionClose=true"/>
 315                     <convertBodyTo type="java.lang.String"/>
 316                     <setProperty propertyName="dcaeResponse">
 317                         <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
 318                                 method="convertDcaeResponse(${body})"/>
 319                     </setProperty>
 320                     <setProperty propertyName="dcaeStatusUrl">
 321                         <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
 322                                 method="getStatusUrl(${exchangeProperty[dcaeResponse]})"/>
 323                     </setProperty>
 324                     <to
 325                             uri="bean:org.onap.clamp.loop.LoopService?method=updateDcaeDeploymentFields(${exchangeProperty[loopObject]},null,${exchangeProperty[dcaeStatusUrl]})"/>
 326                     <doFinally>
 327                         <to uri="direct:reset-raise-http-exception-flag"/>
 328                         <to
 329                                 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()"/>
 330                         <setProperty propertyName="logMessage">
 331                             <simple>UNDEPLOY loop status</simple>
 332                         </setProperty>
 333                         <setProperty propertyName="logComponent">
 334                             <simple>DCAE</simple>
 335                         </setProperty>
 336                         <to uri="direct:dump-loop-log-http-response"/>
 337                     </doFinally>
 338                 </doTry>
 339             </when>
 340             <otherwise>
 341                 <log loggingLevel="WARNING"
 342                      message="Cannot Undeploy for the loop: ${exchangeProperty[loopObject].getName()}, the Deployment ID does not exist !"/>
 343                 <to
 344                         uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Cannot Undeploy for the loop: ${exchangeProperty[loopObject].getName()}, the Deployment ID does not exist !','WARNING',${exchangeProperty[loopObject]})"/>
 345             </otherwise>
 346         </choice>
 347     </route>
 348     <route id="get-dcae-deployment-status">
 349         <from uri="direct:get-dcae-deployment-status"/>
 350         <log loggingLevel="INFO"
 351              message="Getting DCAE deployment status for loop: ${exchangeProperty[loopObject].getName()} - ${exchangeProperty[dcaeComponent].getComponentName()}"/>
 352         <to
 353                 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting Deployment status')"/>
 354         <doTry>
 355             <setHeader headerName="CamelHttpMethod">
 356                 <constant>GET</constant>
 357             </setHeader>
 358             <setHeader headerName="X-ONAP-RequestID">
 359                 <simple>${exchangeProperty[X-ONAP-RequestID]}
 360                 </simple>
 361             </setHeader>
 362             <setHeader headerName="X-ONAP-InvocationID">
 363                 <simple>${exchangeProperty[X-ONAP-InvocationID]}
 364                 </simple>
 365             </setHeader>
 366             <setHeader headerName="X-ONAP-PartnerName">
 367                 <simple>${exchangeProperty[X-ONAP-PartnerName]}
 368                 </simple>
 369             </setHeader>
 370             <log loggingLevel="INFO"
 371                  message="Endpoint to query microservice deployment status: ${exchangeProperty[getStatusUrlModified]}"></log>
 372             <choice>
 373                 <when>
 374                     <simple>${exchangeProperty[getStatusUrl].contains("?")} == true
 375                     </simple>
 376                     <setProperty propertyName="uriSeparator">
 377                         <simple>&amp;</simple>
 378                     </setProperty>
 379                 </when>
 380                 <otherwise>
 381                     <setProperty propertyName="uriSeparator">
 382                         <simple>?</simple>
 383                     </setProperty>
 384                 </otherwise>
 385             </choice>
 386             <toD
 387                     uri="${exchangeProperty[getStatusUrl]}${exchangeProperty[uriSeparator]}bridgeEndpoint=true&amp;useSystemProperties=true&amp;throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&amp;authMethod=Basic&amp;authUsername={{clamp.config.dcae.deployment.userName}}&amp;authPassword={{clamp.config.dcae.deployment.password}}&amp;httpClient.connectTimeout=10000&amp;httpClient.socketTimeout=30000&amp;authenticationPreemptive=true&amp;connectionClose=true"/>
 388             <doCatch>
 389                 <exception>java.lang.Exception</exception>
 390                 <handled>
 391                     <constant>true</constant>
 392                 </handled>
 393
 394                 <log loggingLevel="ERROR"
 395                      message="GET DCAE deployment request FAILED for loop: ${header.loopName}, ${exception.stacktrace}"/>
 396                 <to
 397                         uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('GET DCAE deployment request failed, Error reported: ${exception.message}','ERROR',${exchangeProperty[loopObject]})"/>
 398             </doCatch>
 399             <doFinally>
 400                 <to uri="direct:reset-raise-http-exception-flag"/>
 401                 <to
 402                         uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()"/>
 403                 <setProperty propertyName="logMessage">
 404                     <simple>DCAE deployment status</simple>
 405                 </setProperty>
 406                 <setProperty propertyName="logComponent">
 407                     <simple>DCAE</simple>
 408                 </setProperty>
 409                 <to uri="direct:dump-loop-log-http-response"/>
 410             </doFinally>
 411         </doTry>
 412     </route>
 413     <route id="get-dcae-blueprint-inventory">
 414         <from uri="direct:get-dcae-blueprint-inventory"/>
 415         <log loggingLevel="INFO"
 416              message="Getting DCAE blueprint id in inventory"/>
 417         <to
 418                 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting blueprint id in inventory')"/>
 419         <doTry>
 420             <setHeader headerName="CamelHttpMethod">
 421                 <constant>GET</constant>
 422             </setHeader>
 423             <setHeader headerName="X-ONAP-RequestID">
 424                 <simple>${exchangeProperty[X-ONAP-RequestID]}
 425                 </simple>
 426             </setHeader>
 427             <setHeader headerName="X-ONAP-InvocationID">
 428                 <simple>${exchangeProperty[X-ONAP-InvocationID]}
 429                 </simple>
 430             </setHeader>
 431             <setHeader headerName="X-ONAP-PartnerName">
 432                 <simple>${exchangeProperty[X-ONAP-PartnerName]}
 433                 </simple>
 434             </setHeader>
 435             <log loggingLevel="INFO"
 436                  message="Endpoint to query Dcae inventory Loop status: {{clamp.config.dcae.inventory.url}}/dcae-service-types?${header[CamelHttpQuery]}"></log>
 437             <toD
 438                     uri="{{clamp.config.dcae.inventory.url}}/dcae-service-types?asdcResourceId=${exchangeProperty[blueprintResourceId]}&amp;asdcServiceId=${exchangeProperty[blueprintServiceId]}&amp;typeName=${exchangeProperty[blueprintName]}&amp;bridgeEndpoint=true&amp;useSystemProperties=true&amp;throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&amp;authMethod=Basic&amp;authUsername={{clamp.config.dcae.deployment.userName}}&amp;authPassword={{clamp.config.dcae.deployment.password}}&amp;httpClient.connectTimeout=10000&amp;httpClient.socketTimeout=30000&amp;authenticationPreemptive=true&amp;connectionClose=true"/>
 439             <convertBodyTo type="java.lang.String"/>
 440             <doFinally>
 441                 <to uri="direct:reset-raise-http-exception-flag"/>
 442                 <to
 443                         uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()"/>
 444             </doFinally>
 445         </doTry>
 446
 447     </route>
 448     <route id="get-all-dcae-blueprint-inventory">
 449         <from uri="direct:get-all-dcae-blueprint-inventory"/>
 450         <log loggingLevel="INFO"
 451              message="Getting all DCAE blueprint from inventory"/>
 452         <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeLog('DCAE', 'Getting all blueprint from inventory')"/>
 453         <doTry>
 454             <setHeader headerName="CamelHttpMethod">
 455                 <constant>GET</constant>
 456             </setHeader>
 457             <setHeader headerName="X-ONAP-RequestID">
 458                 <simple>${exchangeProperty[X-ONAP-RequestID]}
 459                 </simple>
 460             </setHeader>
 461             <setHeader headerName="X-ONAP-InvocationID">
 462                 <simple>${exchangeProperty[X-ONAP-InvocationID]}
 463                 </simple>
 464             </setHeader>
 465             <setHeader headerName="X-ONAP-PartnerName">
 466                 <simple>${exchangeProperty[X-ONAP-PartnerName]}
 467                 </simple>
 468             </setHeader>
 469             <log loggingLevel="INFO"
 470                  message="Endpoint to query Blueprints from DCAE inventory: {{clamp.config.dcae.inventory.url}}/dcae-service-types?${header[CamelHttpQuery]}"></log>
 471             <toD uri="{{clamp.config.dcae.inventory.url}}/dcae-service-types;bridgeEndpoint=true&amp;useSystemProperties=true&amp;throwExceptionOnFailure=${exchangeProperty[raiseHttpExceptionFlag]}&amp;authMethod=Basic&amp;authUsername={{clamp.config.dcae.deployment.userName}}&amp;authPassword={{clamp.config.dcae.deployment.password}}&amp;httpClient.connectTimeout=10000&amp;httpClient.socketTimeout=30000&amp;authenticationPreemptive=true&amp;connectionClose=true"/>
 472             <convertBodyTo type="java.lang.String"/>
 473             <setProperty propertyName="dcaeResponseList">
 474                 <method ref="org.onap.clamp.loop.components.external.DcaeComponent"
 475                         method="convertToDcaeInventoryResponse(${body})"/>
 476             </setProperty>
 477             <split>
 478                 <simple>${exchangeProperty[dcaeResponseList]}</simple>
 479                 <convertBodyTo type="org.onap.clamp.clds.model.dcae.DcaeInventoryResponse"/>
 480                 <setProperty propertyName="dcaeResponse">
 481                     <simple>${body}</simple>
 482                 </setProperty>
 483                 <to uri="bean:org.onap.clamp.clds.model.dcae.DcaeInventoryCache?method=addDcaeInventoryResponse(${exchangeProperty[dcaeResponse]})"/>
 484             </split>
 485             <doFinally>
 486                 <to uri="direct:reset-raise-http-exception-flag"/>
 487                 <to uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=invokeReturnLog()"/>
 488             </doFinally>
 489         </doTry>
 490     </route>
 491 </routes>