Updated xml tags and moved sleep to bpmn

Per issue, changed "_" to "-".  Also related to a comment to SO-303,
made "sleep" time a property and moved the sleep calls from groovy
scripts to bpmn.
Fixed a few test resources that still had "_" instead of "-".  Changed
variable name from sdnReplDelay to sdncReplDelay.

Change-Id: I893254c0ab735508732fcf2c3e82934f26c2a05a
Issue-Id: SO-308
Signed-off-by: Jim Hahn <jrh3@att.com>

diff --git a/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/vcpe/scripts/CreateVcpeResCustService.groovy b/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/vcpe/scripts/CreateVcpeResCustService.groovy
index dba1a8b..703ea8b 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/vcpe/scripts/CreateVcpeResCustService.groovy
+++ b/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/vcpe/scripts/CreateVcpeResCustService.groovy
@@ -40,6 +40,7 @@ import org.json.JSONArray;
 import org.apache.commons.lang3.*\r
 import org.apache.commons.codec.binary.Base64;\r
 import org.springframework.web.util.UriUtils;\r
+import static org.apache.commons.lang3.StringUtils.*\r
 \r
 /**\r
  * This groovy class supports the <class>CreateVcpeResCustService.bpmn</class> process.\r
@@ -93,6 +94,16 @@ public class CreateVcpeResCustService extends AbstractServiceTaskProcessor {
                        // initialize flow variables\r
                        InitializeProcessVariables(execution)\r
 \r
+                       //Config Inputs\r
+                       String aaiDistDelay = execution.getVariable('URN_mso_workflow_aai_distribution_delay')\r
+                       if (isBlank(aaiDistDelay)) {\r
+                               msg = "URN_mso_workflow_aai_distribution_delay is null"\r
+                               utils.log("DEBUG", msg, isDebugEnabled)\r
+                               exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)\r
+                       }\r
+                       execution.setVariable("aaiDistDelay", aaiDistDelay)\r
+                       utils.log("DEBUG","AAI distribution delay: " + aaiDistDelay, isDebugEnabled)\r
+\r
                        // check for incoming json message/input\r
                        String createVcpeServiceRequest = execution.getVariable("bpmnRequest")\r
                        utils.logAudit(createVcpeServiceRequest)\r
@@ -363,24 +374,6 @@ public class CreateVcpeResCustService extends AbstractServiceTaskProcessor {
        }\r
 \r
 \r
-       public void awaitAaiDistribution(Execution execution) {\r
-               def isDebugEnabled=execution.getVariable(DebugFlag)\r
-\r
-               try {\r
-                       String tsleep = execution.getVariable("junitSleepMs")\r
-                       \r
-                       //workaround for aai replication issue\r
-                       utils.log("DEBUG", "sleeping while AAI distributes data", isDebugEnabled)\r
-                       sleep(tsleep == null ? 30000 : tsleep as Long)\r
-                       \r
-               } catch (Exception ex) {\r
-                       // try error in method block\r
-                       String exceptionMessage = "Unexpected Error from method awaitAaiDistribution() - " + ex.getMessage()\r
-                       exceptionUtil.buildAndThrowWorkflowException(execution, 7000, exceptionMessage)\r
-               }\r
-        }\r
-\r
-\r
        public void prepareCreateAllottedResourceTXC(Execution execution) {\r
                def isDebugEnabled=execution.getVariable(DebugFlag)\r
 \r

diff --git a/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceBRG.groovy b/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceBRG.groovy
index b46721c..54e23a9 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceBRG.groovy
+++ b/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceBRG.groovy
@@ -89,6 +89,15 @@ public class DoCreateAllottedResourceBRG extends AbstractServiceTaskProcessor{
                        execution.setVariable("sdncCallbackUrl", sdncCallbackUrl)
                        utils.log("DEBUG","SDNC Callback URL: " + sdncCallbackUrl, isDebugEnabled)
 
+                       String sdncReplDelay = execution.getVariable('URN_mso_workflow_sdnc_replication_delay')
+                       if (isBlank(sdncReplDelay)) {
+                               msg = "URN_mso_workflow_sdnc_replication_delay is null"
+                               utils.log("DEBUG", msg, isDebugEnabled)
+                               exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+                       }
+                       execution.setVariable("sdncReplDelay", sdncReplDelay)
+                       utils.log("DEBUG","SDNC replication delay: " + sdncReplDelay, isDebugEnabled)
+
                        //Request Inputs
                        if (isBlank(execution.getVariable("serviceInstanceId"))){
                                msg = "Input serviceInstanceId is null"
@@ -562,11 +571,6 @@ public class DoCreateAllottedResourceBRG extends AbstractServiceTaskProcessor{
 
                        String serviceInstanceId = execution.getVariable("serviceInstanceId")
                        String sdncRequestId = UUID.randomUUID().toString()
-                       
-                       String tsleep = execution.getVariable("junitSleepMs")
-                       
-                       //workaround for sdnc replication issue
-                       sleep(tsleep == null ? 5000 : tsleep as Long)
 
                        //neeed the same url as used by vfmodules
                        String SDNCGetRequest =

diff --git a/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceTXC.groovy b/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceTXC.groovy
index 8a4e591..c9edf05 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceTXC.groovy
+++ b/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceTXC.groovy
@@ -93,6 +93,15 @@ public class DoCreateAllottedResourceTXC extends AbstractServiceTaskProcessor{
                        execution.setVariable("sdncCallbackUrl", sdncCallbackUrl)
                        utils.log("DEBUG","SDNC Callback URL: " + sdncCallbackUrl, isDebugEnabled)
 
+                       String sdncReplDelay = execution.getVariable('URN_mso_workflow_sdnc_replication_delay')
+                       if (isBlank(sdncReplDelay)) {
+                               msg = "URN_mso_workflow_sdnc_replication_delay is null"
+                               utils.log("DEBUG", msg, isDebugEnabled)
+                               exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+                       }
+                       execution.setVariable("sdncReplDelay", sdncReplDelay)
+                       utils.log("DEBUG","SDNC replication delay: " + sdncReplDelay, isDebugEnabled)
+
                        //Request Inputs
                        if (isBlank(execution.getVariable("serviceInstanceId"))){
                                msg = "Input serviceInstanceId is null"
@@ -554,11 +563,6 @@ public class DoCreateAllottedResourceTXC extends AbstractServiceTaskProcessor{
 
                        String serviceInstanceId = execution.getVariable("serviceInstanceId")
                        String sdncRequestId = UUID.randomUUID().toString()
-                       
-                       String tsleep = execution.getVariable("junitSleepMs")
-                       
-                       //workaround for sdnc replication issue
-                       sleep(tsleep == null ? 5000 : tsleep as Long)
 
                        //neeed the same url as used by vfmodules
                        String SDNCGetRequest =
@@ -606,8 +610,8 @@ public class DoCreateAllottedResourceTXC extends AbstractServiceTaskProcessor{
                
                        String txca = utils.getNodeXml(arData, "tunnelxconn-assignments")
                        execution.setVariable("vni", utils.getNodeText1(txca, "vni"))
-                       execution.setVariable("vgmuxBearerIP", utils.getNodeText1(txca, "vgmux_bearer_ip"))
-                       execution.setVariable("vgmuxLanIP", utils.getNodeText1(txca, "vgmux_lan_ip"))
+                       execution.setVariable("vgmuxBearerIP", utils.getNodeText1(txca, "vgmux-bearer-ip"))
+                       execution.setVariable("vgmuxLanIP", utils.getNodeText1(txca, "vgmux-lan-ip"))
                        
                        String ari = utils.getNodeXml(arData, "allotted-resource-identifiers")
                        execution.setVariable("allotedResourceName", utils.getNodeText1(ari, "allotted-resource-name"))

diff --git a/bpmn/MSOInfrastructureBPMN/src/main/resources/process/CreateVcpeResCustService.bpmn b/bpmn/MSOInfrastructureBPMN/src/main/resources/process/CreateVcpeResCustService.bpmn
index 3c5e268..175efaf 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/main/resources/process/CreateVcpeResCustService.bpmn
+++ b/bpmn/MSOInfrastructureBPMN/src/main/resources/process/CreateVcpeResCustService.bpmn
@@ -366,9 +366,8 @@ CreateVcpeResCustService.prepareCreateServiceInstance(execution)]]></bpmn2:scrip
         </camunda:connector>
       </bpmn2:extensionElements>
       <bpmn2:incoming>SequenceFlow_0vj46ej</bpmn2:incoming>
-      <bpmn2:outgoing>SequenceFlow_13uceka</bpmn2:outgoing>
+      <bpmn2:outgoing>SequenceFlow_0sjpja4</bpmn2:outgoing>
     </bpmn2:serviceTask>
-    <bpmn2:sequenceFlow id="SequenceFlow_13uceka" sourceRef="updateInfraRequest" targetRef="ScriptTask_1e5rwka" />
     <bpmn2:scriptTask id="ScriptTask_1qd3uwb" name="Post Process&#10;Create&#10;Service&#10;" scriptFormat="groovy">
       <bpmn2:incoming>SequenceFlow_1ky2sv9</bpmn2:incoming>
       <bpmn2:outgoing>SequenceFlow_0vj46ej</bpmn2:outgoing>
@@ -431,7 +430,7 @@ CreateVcpeResCustService.prepareCreateAllottedResourceTXC(execution)]]></bpmn2:s
       <bpmn2:linkEventDefinition name="StartService" />
     </bpmn2:intermediateCatchEvent>
     <bpmn2:intermediateThrowEvent id="IntermediateThrowEvent_1as6hoa" name="GoToCreateAllottedResourcesTXC">
-      <bpmn2:incoming>SequenceFlow_16acruh</bpmn2:incoming>
+      <bpmn2:incoming>SequenceFlow_1db0ri1</bpmn2:incoming>
       <bpmn2:linkEventDefinition name="CreateAllottedResourcesTXC" />
     </bpmn2:intermediateThrowEvent>
     <bpmn2:sequenceFlow id="SequenceFlow_15odbkz" sourceRef="IntermediateCatchEvent_1i1nwfx" targetRef="prepareCreateService_scriptTask" />
@@ -616,14 +615,15 @@ CreateVcpeResCustService.validateVnfCreate(execution)]]></bpmn2:script>
       <bpmn2:outgoing>SequenceFlow_0e9e6fo</bpmn2:outgoing>
     </bpmn2:callActivity>
     <bpmn2:sequenceFlow id="SequenceFlow_0e9e6fo" sourceRef="CallActivity_0xt1l8t" targetRef="ExclusiveGateway_0jqgskx" />
-    <bpmn2:scriptTask id="ScriptTask_1e5rwka" name="Await AAI Distribution" scriptFormat="groovy">
-      <bpmn2:incoming>SequenceFlow_13uceka</bpmn2:incoming>
-      <bpmn2:outgoing>SequenceFlow_16acruh</bpmn2:outgoing>
-      <bpmn2:script><![CDATA[import org.openecomp.mso.bpmn.vcpe.scripts.*
-def CreateVcpeResCustService = new CreateVcpeResCustService()
-CreateVcpeResCustService.awaitAaiDistribution(execution)]]></bpmn2:script>
-    </bpmn2:scriptTask>
-    <bpmn2:sequenceFlow id="SequenceFlow_16acruh" sourceRef="ScriptTask_1e5rwka" targetRef="IntermediateThrowEvent_1as6hoa" />
+    <bpmn2:intermediateCatchEvent id="IntermediateCatchEvent_1x88t9v" name="Await AAI Distribution&#10;&#10;">
+      <bpmn2:incoming>SequenceFlow_0sjpja4</bpmn2:incoming>
+      <bpmn2:outgoing>SequenceFlow_1db0ri1</bpmn2:outgoing>
+      <bpmn2:timerEventDefinition>
+        <bpmn2:timeDuration xsi:type="bpmn2:tFormalExpression">${aaiDistDelay}</bpmn2:timeDuration>
+      </bpmn2:timerEventDefinition>
+    </bpmn2:intermediateCatchEvent>
+    <bpmn2:sequenceFlow id="SequenceFlow_0sjpja4" sourceRef="updateInfraRequest" targetRef="IntermediateCatchEvent_1x88t9v" />
+    <bpmn2:sequenceFlow id="SequenceFlow_1db0ri1" sourceRef="IntermediateCatchEvent_1x88t9v" targetRef="IntermediateThrowEvent_1as6hoa" />
   </bpmn2:process>
   <bpmn2:error id="Error_2" name="MSOWorkflowException" errorCode="MSOWorkflowException" />
   <bpmn2:error id="Error_1" name="java.lang.Exception" errorCode="java.lang.Exception" />
@@ -921,13 +921,6 @@ CreateVcpeResCustService.awaitAaiDistribution(execution)]]></bpmn2:script>
       <bpmndi:BPMNShape id="ServiceTask_16yhzej_di" bpmnElement="updateInfraRequest">
         <dc:Bounds x="794" y="543" width="100" height="80" />
       </bpmndi:BPMNShape>
-      <bpmndi:BPMNEdge id="SequenceFlow_13uceka_di" bpmnElement="SequenceFlow_13uceka">
-        <di:waypoint xsi:type="dc:Point" x="894" y="583" />
-        <di:waypoint xsi:type="dc:Point" x="995" y="583" />
-        <bpmndi:BPMNLabel>
-          <dc:Bounds x="899.5" y="568" width="90" height="0" />
-        </bpmndi:BPMNLabel>
-      </bpmndi:BPMNEdge>
       <bpmndi:BPMNShape id="ScriptTask_1qd3uwb_di" bpmnElement="ScriptTask_1qd3uwb">
         <dc:Bounds x="623" y="543" width="100" height="80" />
       </bpmndi:BPMNShape>
@@ -1151,9 +1144,9 @@ CreateVcpeResCustService.awaitAaiDistribution(execution)]]></bpmn2:script>
         </bpmndi:BPMNLabel>
       </bpmndi:BPMNShape>
       <bpmndi:BPMNShape id="IntermediateThrowEvent_1as6hoa_di" bpmnElement="IntermediateThrowEvent_1as6hoa">
-        <dc:Bounds x="1027" y="712" width="36" height="36" />
+        <dc:Bounds x="1027" y="666" width="36" height="36" />
         <bpmndi:BPMNLabel>
-          <dc:Bounds x="1002" y="753" width="85" height="36" />
+          <dc:Bounds x="1002" y="707" width="85" height="36" />
         </bpmndi:BPMNLabel>
       </bpmndi:BPMNShape>
       <bpmndi:BPMNEdge id="SequenceFlow_15odbkz_di" bpmnElement="SequenceFlow_15odbkz">
@@ -1508,16 +1501,24 @@ CreateVcpeResCustService.awaitAaiDistribution(execution)]]></bpmn2:script>
           <dc:Bounds x="440" y="1166" width="90" height="12" />
         </bpmndi:BPMNLabel>
       </bpmndi:BPMNEdge>
-      <bpmndi:BPMNShape id="ScriptTask_1e5rwka_di" bpmnElement="ScriptTask_1e5rwka">
-        <dc:Bounds x="995" y="543" width="100" height="80" />
+      <bpmndi:BPMNShape id="IntermediateCatchEvent_1x88t9v_di" bpmnElement="IntermediateCatchEvent_1x88t9v">
+        <dc:Bounds x="1027" y="565" width="36" height="36" />
+        <bpmndi:BPMNLabel>
+          <dc:Bounds x="1018" y="530" width="54" height="48" />
+        </bpmndi:BPMNLabel>
       </bpmndi:BPMNShape>
-      <bpmndi:BPMNEdge id="SequenceFlow_16acruh_di" bpmnElement="SequenceFlow_16acruh">
-        <di:waypoint xsi:type="dc:Point" x="1045" y="623" />
-        <di:waypoint xsi:type="dc:Point" x="1045" y="663" />
-        <di:waypoint xsi:type="dc:Point" x="1045" y="663" />
-        <di:waypoint xsi:type="dc:Point" x="1045" y="712" />
+      <bpmndi:BPMNEdge id="SequenceFlow_0sjpja4_di" bpmnElement="SequenceFlow_0sjpja4">
+        <di:waypoint xsi:type="dc:Point" x="894" y="583" />
+        <di:waypoint xsi:type="dc:Point" x="1027" y="583" />
+        <bpmndi:BPMNLabel>
+          <dc:Bounds x="960.5" y="562" width="0" height="12" />
+        </bpmndi:BPMNLabel>
+      </bpmndi:BPMNEdge>
+      <bpmndi:BPMNEdge id="SequenceFlow_1db0ri1_di" bpmnElement="SequenceFlow_1db0ri1">
+        <di:waypoint xsi:type="dc:Point" x="1045" y="601" />
+        <di:waypoint xsi:type="dc:Point" x="1045" y="666" />
         <bpmndi:BPMNLabel>
-          <dc:Bounds x="1060" y="657" width="0" height="12" />
+          <dc:Bounds x="1060" y="627.5" width="0" height="12" />
         </bpmndi:BPMNLabel>
       </bpmndi:BPMNEdge>
     </bpmndi:BPMNPlane>

diff --git a/bpmn/MSOInfrastructureBPMN/src/main/resources/subprocess/DoCreateAllottedResourceBRG.bpmn b/bpmn/MSOInfrastructureBPMN/src/main/resources/subprocess/DoCreateAllottedResourceBRG.bpmn
index a35371e..b925b00 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/main/resources/subprocess/DoCreateAllottedResourceBRG.bpmn
+++ b/bpmn/MSOInfrastructureBPMN/src/main/resources/subprocess/DoCreateAllottedResourceBRG.bpmn
@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<bpmn2:definitions xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:bpmn2="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" id="_DkzPAHB4EeaJwpcpVN5gXw" targetNamespace="http://camunda.org/schema/1.0/bpmn" exporter="Camunda Modeler" exporterVersion="1.4.0" xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd">
+<bpmn2:definitions xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:bpmn2="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" id="_DkzPAHB4EeaJwpcpVN5gXw" targetNamespace="http://camunda.org/schema/1.0/bpmn" exporter="Camunda Modeler" exporterVersion="1.9.0" xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd">
   <bpmn2:process id="DoCreateAllottedResourceBRG" name="DoCreateAllottedResourceBRG" isExecutable="true">
     <bpmn2:startEvent id="StartEvent_1">
       <bpmn2:outgoing>SequenceFlow_1</bpmn2:outgoing>
@@ -180,7 +180,7 @@ dcar.validateSDNCResp(execution, response, "activate" )]]></bpmn2:script>
       <bpmn2:outgoing>SequenceFlow_0q1hz2p</bpmn2:outgoing>
     </bpmn2:callActivity>
     <bpmn2:sequenceFlow id="SequenceFlow_1iy3cqb" sourceRef="postProcessSDNCGetResponse" targetRef="generateOutputs" />
-    <bpmn2:sequenceFlow id="SequenceFlow_1dgzhsm" sourceRef="UpdateAAIARActive" targetRef="PreProcessSDNCGet" />
+    <bpmn2:sequenceFlow id="SequenceFlow_1dgzhsm" sourceRef="UpdateAAIARActive" targetRef="IntermediateCatchEvent_1f4tse6" />
     <bpmn2:callActivity id="GetAAIParentSI" name="Get AAI  Parent ServiceInstance&#10;" calledElement="GenericGetService">
       <bpmn2:extensionElements>
         <camunda:in source="parentServiceInstanceId" target="GENGS_serviceInstanceId" />
@@ -277,8 +277,8 @@ DoCreateAllottedResourceBRG dcar = new DoCreateAllottedResourceBRG()
 dcar.updateAaiAROrchStatus(execution, "Created")]]></bpmn2:script>
     </bpmn2:scriptTask>
     <bpmn2:scriptTask id="PreProcessSDNCGet" name="PreProcess SDNC Get" scriptFormat="groovy">
-      <bpmn2:incoming>SequenceFlow_1dgzhsm</bpmn2:incoming>
       <bpmn2:incoming>SequenceFlow_0z8luou</bpmn2:incoming>
+      <bpmn2:incoming>SequenceFlow_0ec9eiq</bpmn2:incoming>
       <bpmn2:outgoing>SequenceFlow_030mhcm</bpmn2:outgoing>
       <bpmn2:script><![CDATA[import org.openecomp.mso.bpmn.vcpe.scripts.*
 DoCreateAllottedResourceBRG dcar = new DoCreateAllottedResourceBRG()
@@ -326,6 +326,14 @@ DoCreateAllottedResourceBRG dcar = new DoCreateAllottedResourceBRG()
 dcar.generateOutputs(execution)]]></bpmn2:script>
     </bpmn2:scriptTask>
     <bpmn2:sequenceFlow id="SequenceFlow_09xwplc" sourceRef="generateOutputs" targetRef="EndEvent_3" />
+    <bpmn2:intermediateCatchEvent id="IntermediateCatchEvent_1f4tse6" name="Await SDNC Replication&#10;&#10;">
+      <bpmn2:incoming>SequenceFlow_1dgzhsm</bpmn2:incoming>
+      <bpmn2:outgoing>SequenceFlow_0ec9eiq</bpmn2:outgoing>
+      <bpmn2:timerEventDefinition>
+        <bpmn2:timeDuration xsi:type="bpmn2:tFormalExpression">${sdncReplDelay}</bpmn2:timeDuration>
+      </bpmn2:timerEventDefinition>
+    </bpmn2:intermediateCatchEvent>
+    <bpmn2:sequenceFlow id="SequenceFlow_0ec9eiq" sourceRef="IntermediateCatchEvent_1f4tse6" targetRef="PreProcessSDNCGet" />
   </bpmn2:process>
   <bpmn2:error id="Error_1" name="Java Lang Exception" errorCode="java.lang.Exception" />
   <bpmn2:error id="Error_2" name="MSO Workflow Exception" errorCode="MSOWorkflowException" />
@@ -532,10 +540,9 @@ dcar.generateOutputs(execution)]]></bpmn2:script>
       </bpmndi:BPMNEdge>
       <bpmndi:BPMNEdge id="SequenceFlow_1dgzhsm_di" bpmnElement="SequenceFlow_1dgzhsm">
         <di:waypoint xsi:type="dc:Point" x="964" y="624" />
-        <di:waypoint xsi:type="dc:Point" x="964" y="545" />
-        <di:waypoint xsi:type="dc:Point" x="1140" y="545" />
+        <di:waypoint xsi:type="dc:Point" x="964" y="563" />
         <bpmndi:BPMNLabel>
-          <dc:Bounds x="979" y="584.5" width="0" height="0" />
+          <dc:Bounds x="934" y="593.5" width="90" height="0" />
         </bpmndi:BPMNLabel>
       </bpmndi:BPMNEdge>
       <bpmndi:BPMNShape id="CallActivity_0e73um9_di" bpmnElement="GetAAIParentSI">
@@ -730,6 +737,19 @@ dcar.generateOutputs(execution)]]></bpmn2:script>
           <dc:Bounds x="575" y="980" width="0" height="0" />
         </bpmndi:BPMNLabel>
       </bpmndi:BPMNEdge>
+      <bpmndi:BPMNShape id="IntermediateCatchEvent_1f4tse6_di" bpmnElement="IntermediateCatchEvent_1f4tse6">
+        <dc:Bounds x="946" y="527" width="36" height="36" />
+        <bpmndi:BPMNLabel>
+          <dc:Bounds x="933" y="492" width="61" height="48" />
+        </bpmndi:BPMNLabel>
+      </bpmndi:BPMNShape>
+      <bpmndi:BPMNEdge id="SequenceFlow_0ec9eiq_di" bpmnElement="SequenceFlow_0ec9eiq">
+        <di:waypoint xsi:type="dc:Point" x="982" y="545" />
+        <di:waypoint xsi:type="dc:Point" x="1140" y="545" />
+        <bpmndi:BPMNLabel>
+          <dc:Bounds x="1061" y="524" width="0" height="12" />
+        </bpmndi:BPMNLabel>
+      </bpmndi:BPMNEdge>
     </bpmndi:BPMNPlane>
   </bpmndi:BPMNDiagram>
 </bpmn2:definitions>

diff --git a/bpmn/MSOInfrastructureBPMN/src/main/resources/subprocess/DoCreateAllottedResourceTXC.bpmn b/bpmn/MSOInfrastructureBPMN/src/main/resources/subprocess/DoCreateAllottedResourceTXC.bpmn
index 178534f..a240bb5 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/main/resources/subprocess/DoCreateAllottedResourceTXC.bpmn
+++ b/bpmn/MSOInfrastructureBPMN/src/main/resources/subprocess/DoCreateAllottedResourceTXC.bpmn
@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<bpmn2:definitions xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:bpmn2="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" id="_DkzPAHB4EeaJwpcpVN5gXw" targetNamespace="http://camunda.org/schema/1.0/bpmn" exporter="Camunda Modeler" exporterVersion="1.4.0" xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd">
+<bpmn2:definitions xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:bpmn2="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" id="_DkzPAHB4EeaJwpcpVN5gXw" targetNamespace="http://camunda.org/schema/1.0/bpmn" exporter="Camunda Modeler" exporterVersion="1.9.0" xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd">
   <bpmn2:process id="DoCreateAllottedResourceTXC" name="DoCreateAllottedResourceTXC" isExecutable="true">
     <bpmn2:startEvent id="StartEvent_1">
       <bpmn2:outgoing>SequenceFlow_1</bpmn2:outgoing>
@@ -180,7 +180,6 @@ dcar.validateSDNCResp(execution, response, "activate" )]]></bpmn2:script>
       <bpmn2:outgoing>SequenceFlow_0q1hz2p</bpmn2:outgoing>
     </bpmn2:callActivity>
     <bpmn2:sequenceFlow id="SequenceFlow_1iy3cqb" sourceRef="postProcessSDNCGetResponse" targetRef="generateOutputs" />
-    <bpmn2:sequenceFlow id="SequenceFlow_1dgzhsm" sourceRef="UpdateAAIARActive" targetRef="PreProcessSDNCGet" />
     <bpmn2:callActivity id="GetAAIParentSI" name="Get AAI  Parent ServiceInstance&#10;" calledElement="GenericGetService">
       <bpmn2:extensionElements>
         <camunda:in source="parentServiceInstanceId" target="GENGS_serviceInstanceId" />
@@ -262,7 +261,7 @@ dcar.postProcessRollback(execution)]]></bpmn2:script>
     </bpmn2:subProcess>
     <bpmn2:scriptTask id="UpdateAAIARActive" name="Update AAI AR Active" scriptFormat="groovy">
       <bpmn2:incoming>SequenceFlow_00i7x43</bpmn2:incoming>
-      <bpmn2:outgoing>SequenceFlow_1dgzhsm</bpmn2:outgoing>
+      <bpmn2:outgoing>SequenceFlow_07kxd8t</bpmn2:outgoing>
       <bpmn2:script><![CDATA[import org.openecomp.mso.bpmn.vcpe.scripts.*
 
 DoCreateAllottedResourceTXC dcar = new DoCreateAllottedResourceTXC()
@@ -277,8 +276,8 @@ DoCreateAllottedResourceTXC dcar = new DoCreateAllottedResourceTXC()
 dcar.updateAaiAROrchStatus(execution, "Created")]]></bpmn2:script>
     </bpmn2:scriptTask>
     <bpmn2:scriptTask id="PreProcessSDNCGet" name="PreProcess SDNC Get" scriptFormat="groovy">
-      <bpmn2:incoming>SequenceFlow_1dgzhsm</bpmn2:incoming>
       <bpmn2:incoming>SequenceFlow_0z8luou</bpmn2:incoming>
+      <bpmn2:incoming>SequenceFlow_08hhqb2</bpmn2:incoming>
       <bpmn2:outgoing>SequenceFlow_030mhcm</bpmn2:outgoing>
       <bpmn2:script><![CDATA[import org.openecomp.mso.bpmn.vcpe.scripts.*
 DoCreateAllottedResourceTXC dcar = new DoCreateAllottedResourceTXC()
@@ -326,6 +325,15 @@ DoCreateAllottedResourceTXC dcar = new DoCreateAllottedResourceTXC()
 dcar.generateOutputs(execution)]]></bpmn2:script>
     </bpmn2:scriptTask>
     <bpmn2:sequenceFlow id="SequenceFlow_09xwplc" sourceRef="generateOutputs" targetRef="EndEvent_3" />
+    <bpmn2:sequenceFlow id="SequenceFlow_07kxd8t" sourceRef="UpdateAAIARActive" targetRef="IntermediateThrowEvent_0ti2fv8" />
+    <bpmn2:intermediateCatchEvent id="IntermediateThrowEvent_0ti2fv8" name="Await SDNC Replication&#10;&#10;">
+      <bpmn2:incoming>SequenceFlow_07kxd8t</bpmn2:incoming>
+      <bpmn2:outgoing>SequenceFlow_08hhqb2</bpmn2:outgoing>
+      <bpmn2:timerEventDefinition>
+        <bpmn2:timeDuration xsi:type="bpmn2:tFormalExpression">${sdncReplDelay}</bpmn2:timeDuration>
+      </bpmn2:timerEventDefinition>
+    </bpmn2:intermediateCatchEvent>
+    <bpmn2:sequenceFlow id="SequenceFlow_08hhqb2" sourceRef="IntermediateThrowEvent_0ti2fv8" targetRef="PreProcessSDNCGet" />
   </bpmn2:process>
   <bpmn2:error id="Error_1" name="Java Lang Exception" errorCode="java.lang.Exception" />
   <bpmn2:error id="Error_2" name="MSO Workflow Exception" errorCode="MSOWorkflowException" />
@@ -530,14 +538,6 @@ dcar.generateOutputs(execution)]]></bpmn2:script>
           <dc:Bounds x="1277" y="779" width="0" height="0" />
         </bpmndi:BPMNLabel>
       </bpmndi:BPMNEdge>
-      <bpmndi:BPMNEdge id="SequenceFlow_1dgzhsm_di" bpmnElement="SequenceFlow_1dgzhsm">
-        <di:waypoint xsi:type="dc:Point" x="964" y="624" />
-        <di:waypoint xsi:type="dc:Point" x="964" y="545" />
-        <di:waypoint xsi:type="dc:Point" x="1140" y="545" />
-        <bpmndi:BPMNLabel>
-          <dc:Bounds x="979" y="584.5" width="0" height="0" />
-        </bpmndi:BPMNLabel>
-      </bpmndi:BPMNEdge>
       <bpmndi:BPMNShape id="CallActivity_0e73um9_di" bpmnElement="GetAAIParentSI">
         <dc:Bounds x="843" y="199" width="100" height="80" />
       </bpmndi:BPMNShape>
@@ -730,6 +730,26 @@ dcar.generateOutputs(execution)]]></bpmn2:script>
           <dc:Bounds x="575" y="980" width="0" height="0" />
         </bpmndi:BPMNLabel>
       </bpmndi:BPMNEdge>
+      <bpmndi:BPMNEdge id="SequenceFlow_07kxd8t_di" bpmnElement="SequenceFlow_07kxd8t">
+        <di:waypoint xsi:type="dc:Point" x="964" y="624" />
+        <di:waypoint xsi:type="dc:Point" x="964" y="563" />
+        <bpmndi:BPMNLabel>
+          <dc:Bounds x="979" y="587.5" width="0" height="12" />
+        </bpmndi:BPMNLabel>
+      </bpmndi:BPMNEdge>
+      <bpmndi:BPMNShape id="IntermediateCatchEvent_038xgwf_di" bpmnElement="IntermediateThrowEvent_0ti2fv8">
+        <dc:Bounds x="946" y="527" width="36" height="36" />
+        <bpmndi:BPMNLabel>
+          <dc:Bounds x="933" y="492" width="61" height="48" />
+        </bpmndi:BPMNLabel>
+      </bpmndi:BPMNShape>
+      <bpmndi:BPMNEdge id="SequenceFlow_08hhqb2_di" bpmnElement="SequenceFlow_08hhqb2">
+        <di:waypoint xsi:type="dc:Point" x="982" y="545" />
+        <di:waypoint xsi:type="dc:Point" x="1140" y="545" />
+        <bpmndi:BPMNLabel>
+          <dc:Bounds x="1061" y="524" width="0" height="12" />
+        </bpmndi:BPMNLabel>
+      </bpmndi:BPMNEdge>
     </bpmndi:BPMNPlane>
   </bpmndi:BPMNDiagram>
 </bpmn2:definitions>

diff --git a/bpmn/MSOInfrastructureBPMN/src/test/groovy/org/openecomp/mso/bpmn/vcpe/scripts/CreateVcpeResCustServiceTest.groovy b/bpmn/MSOInfrastructureBPMN/src/test/groovy/org/openecomp/mso/bpmn/vcpe/scripts/CreateVcpeResCustServiceTest.groovy
index f646eae..f0645b2 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/test/groovy/org/openecomp/mso/bpmn/vcpe/scripts/CreateVcpeResCustServiceTest.groovy
+++ b/bpmn/MSOInfrastructureBPMN/src/test/groovy/org/openecomp/mso/bpmn/vcpe/scripts/CreateVcpeResCustServiceTest.groovy
@@ -85,7 +85,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** preProcessRequest *****\r
                        \r
        @Test\r
-       @Ignore  \r
+       // @Ignore  \r
        public void preProcessRequest() {\r
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -96,6 +96,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
 \r
                verify(mex).getVariable(DBGFLAG)\r
                verify(mex).setVariable("prefix", Prefix)
+               verify(mex).setVariable("aaiDistDelay", "aaidelay")
                verify(mex).setVariable("createVcpeServiceRequest", request)
                verify(mex).setVariable("msoRequestId", "mri")
                assertEquals("sii", map.get("serviceInstanceId"))
@@ -118,7 +119,21 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
+       public void preProcessRequest_MissingAaiDistDelay() {
+               ExecutionEntity mex = setupMock()
+               def map = setupMap(mex)
+               initPreProcess(mex)
+               
+               when(mex.getVariable("URN_mso_workflow_aai_distribution_delay")).thenReturn(null)
+               
+               CreateVcpeResCustService CreateVcpeResCustService = new CreateVcpeResCustService()
+               
+               assertTrue(doBpmnError( { _ -> CreateVcpeResCustService.preProcessRequest(mex) }))
+       }
+                       
+       @Test
+       // @Ignore  
        public void preProcessRequest_EmptyParts() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -160,7 +175,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void preProcessRequest_MissingSubscriberId() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -178,7 +193,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void preProcessRequest_BpmnError() {
                ExecutionEntity mex = setupMock()
                initPreProcess(mex)
@@ -191,7 +206,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void preProcessRequest_Ex() {
                ExecutionEntity mex = setupMock()
                initPreProcess(mex)
@@ -206,7 +221,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** sendSyncResponse *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void sendSyncResponse() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -229,7 +244,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void sendSyncResponse_Ex() {
                ExecutionEntity mex = setupMock()
                initSendSyncResponse(mex)
@@ -245,7 +260,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** prepareDecomposeService *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareDecomposeService() {
                ExecutionEntity mex = setupMock()
                initPrepareDecomposeService(mex)
@@ -258,7 +273,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareDecomposeService_Ex() {
                ExecutionEntity mex = setupMock()
                initPrepareDecomposeService(mex)
@@ -274,7 +289,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** prepareCreateServiceInstance *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareCreateServiceInstance() {
                ExecutionEntity mex = setupMock()
                initPrepareCreateServiceInstance(mex)
@@ -288,7 +303,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareCreateServiceInstance_Ex() {
                ExecutionEntity mex = setupMock()
                initPrepareCreateServiceInstance(mex)
@@ -304,7 +319,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** postProcessServiceInstanceCreate *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void postProcessServiceInstanceCreate() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -323,7 +338,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void postProcessServiceInstanceCreate_BpmnError() {
                ExecutionEntity mex = setupMock()
                initPostProcessServiceInstanceCreate(mex)
@@ -336,7 +351,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void postProcessServiceInstanceCreate_Ex() {
                ExecutionEntity mex = setupMock()
                initPostProcessServiceInstanceCreate(mex)
@@ -352,7 +367,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** processDecomposition *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void processDecomposition() {
                ExecutionEntity mex = setupMock()
                def svcdecomp = initProcessDecomposition(mex, true, true)
@@ -371,7 +386,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void processDecomposition_EmptyNet_EmptyVnf() {
                ExecutionEntity mex = setupMock()
                def svcdecomp = initProcessDecomposition(mex, true, true)
@@ -392,7 +407,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void processDecomposition_Ex() {
                ExecutionEntity mex = setupMock()
                def svcdecomp = initProcessDecomposition(mex, true, true)
@@ -405,26 +420,10 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
        
        
-       // ***** awaitAaiDistribution *****
-                       
-       @Test
-       @Ignore  
-       public void awaitAaiDistribution() {
-               ExecutionEntity mex = setupMock()
-               initAwaitAaiDistribution(mex)
-               
-               CreateVcpeResCustService CreateVcpeResCustService = new CreateVcpeResCustService()
-               CreateVcpeResCustService.awaitAaiDistribution(mex)
-
-               verify(mex).getVariable(DBGFLAG)
-               verify(mex).getVariable("junitSleepMs")
-       }
-       
-       
        // ***** prepareCreateAllottedResourceTXC *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareCreateAllottedResourceTXC() {
                ExecutionEntity mex = setupMock()
                initPrepareCreateAllottedResourceTXC(mex)
@@ -442,7 +441,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareCreateAllottedResourceTXC_NullArList() {
                ExecutionEntity mex = setupMock()
                def svcdecomp = initPrepareCreateAllottedResourceTXC(mex)
@@ -462,7 +461,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareCreateAllottedResourceTXC_Ex() {
                ExecutionEntity mex = setupMock()
                initPrepareCreateAllottedResourceTXC(mex)
@@ -478,7 +477,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** prepareCreateAllottedResourceBRG *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareCreateAllottedResourceBRG() {
                ExecutionEntity mex = setupMock()
                initPrepareCreateAllottedResourceBRG(mex)
@@ -496,7 +495,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareCreateAllottedResourceBRG_NullArList() {
                ExecutionEntity mex = setupMock()
                def svcdecomp = initPrepareCreateAllottedResourceBRG(mex)
@@ -516,7 +515,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareCreateAllottedResourceBRG_Ex() {
                ExecutionEntity mex = setupMock()
                initPrepareCreateAllottedResourceBRG(mex)
@@ -532,7 +531,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** prepareVnfAndModulesCreate *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareVnfAndModulesCreate() {
                ExecutionEntity mex = setupMock()
                initPrepareVnfAndModulesCreate(mex)
@@ -548,7 +547,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareVnfAndModulesCreate_EmptyList() {
                ExecutionEntity mex = setupMock()
                initPrepareVnfAndModulesCreate(mex)
@@ -566,7 +565,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareVnfAndModulesCreate_NullList() {
                ExecutionEntity mex = setupMock()
                initPrepareVnfAndModulesCreate(mex)
@@ -584,7 +583,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareVnfAndModulesCreate_Ex() {
                ExecutionEntity mex = setupMock()
                initPrepareVnfAndModulesCreate(mex)
@@ -600,7 +599,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** validateVnfCreate *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void validateVnfCreate() {
                ExecutionEntity mex = setupMock()
                initValidateVnfCreate(mex)
@@ -614,7 +613,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void validateVnfCreate_Ex() {
                ExecutionEntity mex = setupMock()
                initValidateVnfCreate(mex)
@@ -630,7 +629,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** postProcessResponse *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void postProcessResponse() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -651,7 +650,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void postProcessResponse_BpmnError() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -665,7 +664,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void postProcessResponse_Ex() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -682,7 +681,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** preProcessRollback *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void preProcessRollback() {
                ExecutionEntity mex = setupMock()
                def wfe = initPreProcessRollback(mex)
@@ -696,7 +695,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void preProcessRollback_NullWfe() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -713,7 +712,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void preProcessRollback_BpmnError() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -730,7 +729,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void preProcessRollback_Ex() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -750,7 +749,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** postProcessRollback *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void postProcessRollback() {
                ExecutionEntity mex = setupMock()
                def wfe = initPostProcessRollback(mex)
@@ -764,7 +763,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void postProcessRollback_NullWfe() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -781,7 +780,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void postProcessRollback_BpmnError() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -794,7 +793,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void postProcessRollback_Ex() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -814,7 +813,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** prepareFalloutRequest *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareFalloutRequest() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -833,7 +832,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void prepareFalloutRequest_Ex() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -849,7 +848,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** sendSyncError *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void sendSyncError() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -873,7 +872,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void sendSyncError_NotWfe() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -899,7 +898,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void sendSyncError_NullWfe() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -925,7 +924,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void sendSyncError_Ex() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -944,7 +943,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        // ***** processJavaException *****
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void processJavaException() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -964,7 +963,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void processJavaException_BpmnError() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -980,7 +979,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        }
                        
        @Test
-       @Ignore  
+       // @Ignore  
        public void processJavaException_Ex() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -1001,6 +1000,7 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        private void initPreProcess(ExecutionEntity mex) {
                when(mex.getVariable(DBGFLAG)).thenReturn("true")
                when(mex.getVariable("bpmnRequest")).thenReturn(request)
+               when(mex.getVariable("URN_mso_workflow_aai_distribution_delay")).thenReturn("aaidelay")
                when(mex.getVariable("mso-request-id")).thenReturn("mri")
                when(mex.getVariable("serviceInstanceId")).thenReturn("sii")
                when(mex.getVariable("requestAction")).thenReturn("ra")
@@ -1055,7 +1055,6 @@ class CreateVcpeResCustServiceTest extends GroovyTestBase {
        
        private initAwaitAaiDistribution(ExecutionEntity mex) {
                when(mex.getVariable(DBGFLAG)).thenReturn("true")
-               when(mex.getVariable("junitSleepMs")).thenReturn("5")
        }
        
        private ServiceDecomposition initPrepareCreateAllottedResourceTXC(ExecutionEntity mex) {

diff --git a/bpmn/MSOInfrastructureBPMN/src/test/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceBRGTest.groovy b/bpmn/MSOInfrastructureBPMN/src/test/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceBRGTest.groovy
index 1d4d3ea..ecf3869 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/test/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceBRGTest.groovy
+++ b/bpmn/MSOInfrastructureBPMN/src/test/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceBRGTest.groovy
@@ -89,6 +89,7 @@ class DoCreateAllottedResourceBRGTest extends GroovyTestBase {
                verify(mex).setVariable("prefix", Prefix)\r
                                
                assertTrue(checkMissingPreProcessRequest("URN_mso_workflow_sdncadapter_callback"))
+               assertTrue(checkMissingPreProcessRequest("URN_mso_workflow_sdnc_replication_delay"))
                assertTrue(checkMissingPreProcessRequest("serviceInstanceId"))
                assertTrue(checkMissingPreProcessRequest("parentServiceInstanceId"))
                assertTrue(checkMissingPreProcessRequest("allottedResourceModelInfo"))
@@ -886,6 +887,7 @@ class DoCreateAllottedResourceBRGTest extends GroovyTestBase {
        private void initPreProcess(ExecutionEntity mex) {
                when(mex.getVariable(DBGFLAG)).thenReturn("true")
                when(mex.getVariable("URN_mso_workflow_sdncadapter_callback")).thenReturn("sdncurn")
+               when(mex.getVariable("URN_mso_workflow_sdnc_replication_delay")).thenReturn("sdncdelay")
                when(mex.getVariable("serviceInstanceId")).thenReturn("sii")
                when(mex.getVariable("parentServiceInstanceId")).thenReturn("psii")
                when(mex.getVariable("allottedResourceModelInfo")).thenReturn("armi")
@@ -963,7 +965,6 @@ class DoCreateAllottedResourceBRGTest extends GroovyTestBase {
                when(mex.getVariable("aaiARGetResponse")).thenReturn("<selflink>arlink</selflink>")
                when(mex.getVariable("sdncAssignResponse")).thenReturn("<response-data>&lt;object-path&gt;assignlink&lt;/object-path&gt;</response-data>")
                when(mex.getVariable("serviceInstanceId")).thenReturn("sii")
-               when(mex.getVariable("junitSleepMs")).thenReturn("5")
                when(mex.getVariable("sdncCallbackUrl")).thenReturn("myurl")
        }
        

diff --git a/bpmn/MSOInfrastructureBPMN/src/test/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceTXCTest.groovy b/bpmn/MSOInfrastructureBPMN/src/test/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceTXCTest.groovy
index 026c490..64d49bb 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/test/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceTXCTest.groovy
+++ b/bpmn/MSOInfrastructureBPMN/src/test/groovy/org/openecomp/mso/bpmn/vcpe/scripts/DoCreateAllottedResourceTXCTest.groovy
@@ -83,7 +83,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** preProcessRequest *****\r
                        \r
        @Test\r
-       @Ignore  \r
+       // @Ignore  \r
        public void preProcessRequest() {\r
                ExecutionEntity mex = setupMock()
                initPreProcess(mex)
@@ -95,6 +95,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
                verify(mex).setVariable("prefix", Prefix)\r
                                
                assertTrue(checkMissingPreProcessRequest("URN_mso_workflow_sdncadapter_callback"))
+               assertTrue(checkMissingPreProcessRequest("URN_mso_workflow_sdnc_replication_delay"))
                assertTrue(checkMissingPreProcessRequest("serviceInstanceId"))
                assertTrue(checkMissingPreProcessRequest("parentServiceInstanceId"))
                assertTrue(checkMissingPreProcessRequest("allottedResourceModelInfo"))
@@ -107,7 +108,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** getAaiAR *****
        
        @Test
-       @Ignore
+       // @Ignore
        public void getAaiAR() {
                MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceTXC/getArTxc.xml")
                
@@ -121,7 +122,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void getAaiAR_Duplicate() {
                MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceTXC/getArTxc.xml")
                
@@ -137,7 +138,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void getAaiAR_NotActive() {
                MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceTXC/getArTxc.xml")
                
@@ -153,7 +154,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void getAaiAR_NoStatus() {
                MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceTXC/getArTxc.xml")
                
@@ -172,7 +173,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** createAaiAR *****
        
        @Test
-       @Ignore
+       // @Ignore
        public void createAaiAR() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -196,7 +197,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void createAaiAR_NoArid_NoModelUuids() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -226,7 +227,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void createAaiAR_MissingPsiLink() {
                ExecutionEntity mex = setupMock()
                initCreateAaiAr(mex)
@@ -241,7 +242,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void createAaiAR_HttpFailed() {
                ExecutionEntity mex = setupMock()
                initCreateAaiAr(mex)
@@ -254,7 +255,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void createAaiAR_BpmnError() {
                ExecutionEntity mex = setupMock()
                initCreateAaiAr(mex)
@@ -269,7 +270,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void createAaiAR_Ex() {
                ExecutionEntity mex = setupMock()
                initCreateAaiAr(mex)
@@ -287,7 +288,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** buildSDNCRequest *****
        
        @Test
-       @Ignore
+       // @Ignore
        public void buildSDNCRequest() {
                ExecutionEntity mex = setupMock()
                initBuildSDNCRequest(mex)
@@ -312,7 +313,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void buildSDNCRequest_Ex() {
                ExecutionEntity mex = setupMock()
                initBuildSDNCRequest(mex)
@@ -328,7 +329,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** preProcessSDNCAssign *****
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessSDNCAssign() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -354,7 +355,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessSDNCAssign_BpmnError() {
                ExecutionEntity mex = setupMock()
                initPreProcessSDNC(mex)
@@ -367,7 +368,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessSDNCAssign_Ex() {
                ExecutionEntity mex = setupMock()
                initPreProcessSDNC(mex)
@@ -383,7 +384,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** preProcessSDNCCreate *****
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessSDNCCreate() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -410,7 +411,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessSDNCCreate_BpmnError() {
                ExecutionEntity mex = setupMock()
                initPreProcessSDNC(mex)
@@ -423,7 +424,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessSDNCCreate_Ex() {
                ExecutionEntity mex = setupMock()
                initPreProcessSDNC(mex)
@@ -439,7 +440,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** preProcessSDNCActivate *****
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessSDNCActivate() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -466,7 +467,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessSDNCActivate_BpmnError() {
                ExecutionEntity mex = setupMock()
                initPreProcessSDNC(mex)
@@ -479,7 +480,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessSDNCActivate_Ex() {
                ExecutionEntity mex = setupMock()
                initPreProcessSDNC(mex)
@@ -495,7 +496,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** validateSDNCResp *****
        
        @Test
-       @Ignore
+       // @Ignore
        public void validateSDNCResp() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -519,7 +520,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void validateSDNCResp_Get() {
                ExecutionEntity mex = setupMock()
                def data = initValidateSDNCResp(mex)
@@ -538,7 +539,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void validateSDNCResp_Unsuccessful() {
                ExecutionEntity mex = setupMock()
                initValidateSDNCResp(mex)
@@ -553,7 +554,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void validateSDNCResp_BpmnError() {
                ExecutionEntity mex = setupMock()
                initValidateSDNCResp(mex)
@@ -567,7 +568,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void validateSDNCResp_Ex() {
                ExecutionEntity mex = setupMock()
                initValidateSDNCResp(mex)
@@ -584,7 +585,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** preProcessSDNCGet *****
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessSDNCGet_FoundAR() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -603,7 +604,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessSDNCGet_NotFoundAR() {
                ExecutionEntity mex = setupMock()
                def map = setupMap(mex)
@@ -624,7 +625,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessSDNCGet_Ex() {
                ExecutionEntity mex = setupMock()
                initPreProcessSDNCGet(mex)
@@ -640,7 +641,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** updateAaiAROrchStatus *****
        
        @Test
-       @Ignore
+       // @Ignore
        public void updateAaiAROrchStatus() {
                MockPatchAllottedResource(CUST, SVC, INST, ARID)
                
@@ -655,7 +656,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** generateOutputs *****
        
        @Test
-       @Ignore
+       // @Ignore
        public void generateOutputs() {
                ExecutionEntity mex = setupMock()
                def txctop = FileUtil.readResourceFile("__files/VCPE/DoCreateAllottedResourceTXC/SDNCTopologyQueryCallback.xml")
@@ -674,7 +675,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void generateOutputs_BadXml() {
                ExecutionEntity mex = setupMock()
                
@@ -689,7 +690,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void generateOutputs_BpmnError() {
                ExecutionEntity mex = setupMock()
                
@@ -704,7 +705,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void generateOutputs_Ex() {
                ExecutionEntity mex = setupMock()
                
@@ -722,7 +723,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** preProcessRollback *****
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessRollback() {
                ExecutionEntity mex = setupMock()
                WorkflowException wfe = mock(WorkflowException.class)
@@ -738,7 +739,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessRollback_NotWFE() {
                ExecutionEntity mex = setupMock()
                
@@ -753,7 +754,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessRollback_BpmnError() {
                ExecutionEntity mex = setupMock()
                
@@ -767,7 +768,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void preProcessRollback_Ex() {
                ExecutionEntity mex = setupMock()
                
@@ -784,7 +785,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        // ***** postProcessRollback *****
        
        @Test
-       @Ignore
+       // @Ignore
        public void postProcessRollback() {
                ExecutionEntity mex = setupMock()
                WorkflowException wfe = mock(WorkflowException.class)
@@ -801,7 +802,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void postProcessRollback_NotWFE() {
                ExecutionEntity mex = setupMock()
                
@@ -817,7 +818,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void postProcessRollback_BpmnError() {
                ExecutionEntity mex = setupMock()
                
@@ -832,7 +833,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        }
        
        @Test
-       @Ignore
+       // @Ignore
        public void postProcessRollback_Ex() {
                ExecutionEntity mex = setupMock()
                
@@ -860,6 +861,7 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
        private void initPreProcess(ExecutionEntity mex) {
                when(mex.getVariable(DBGFLAG)).thenReturn("true")
                when(mex.getVariable("URN_mso_workflow_sdncadapter_callback")).thenReturn("sdncurn")
+               when(mex.getVariable("URN_mso_workflow_sdnc_replication_delay")).thenReturn("sdncdelay")
                when(mex.getVariable("serviceInstanceId")).thenReturn("sii")
                when(mex.getVariable("parentServiceInstanceId")).thenReturn("psii")
                when(mex.getVariable("allottedResourceModelInfo")).thenReturn("armi")
@@ -923,7 +925,6 @@ class DoCreateAllottedResourceTXCTest extends GroovyTestBase {
                when(mex.getVariable("aaiARGetResponse")).thenReturn("<selflink>arlink</selflink>")
                when(mex.getVariable("sdncAssignResponse")).thenReturn("<response-data>&lt;object-path&gt;assignlink&lt;/object-path&gt;</response-data>")
                when(mex.getVariable("serviceInstanceId")).thenReturn("sii")
-               when(mex.getVariable("junitSleepMs")).thenReturn("5")
                when(mex.getVariable("sdncCallbackUrl")).thenReturn("myurl")
        }
        

diff --git a/bpmn/MSOInfrastructureBPMN/src/test/java/org/openecomp/mso/bpmn/vcpe/CreateVcpeResCustServiceTest.java b/bpmn/MSOInfrastructureBPMN/src/test/java/org/openecomp/mso/bpmn/vcpe/CreateVcpeResCustServiceTest.java
index 38461de..0af43a2 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/test/java/org/openecomp/mso/bpmn/vcpe/CreateVcpeResCustServiceTest.java
+++ b/bpmn/MSOInfrastructureBPMN/src/test/java/org/openecomp/mso/bpmn/vcpe/CreateVcpeResCustServiceTest.java
@@ -371,7 +371,6 @@ public class CreateVcpeResCustServiceTest extends AbstractTestBase {
                variables.put("request-id", "testRequestId");
                variables.put("serviceInstanceId", DEC_INST);
                variables.put("allottedResourceId", ARID);
-               variables.put("junitSleepMs", "5");
                return variables;
 
        }

diff --git a/bpmn/MSOInfrastructureBPMN/src/test/java/org/openecomp/mso/bpmn/vcpe/DoCreateAllottedResourceBRGTest.java b/bpmn/MSOInfrastructureBPMN/src/test/java/org/openecomp/mso/bpmn/vcpe/DoCreateAllottedResourceBRGTest.java
index 5b6f74f..0373266 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/test/java/org/openecomp/mso/bpmn/vcpe/DoCreateAllottedResourceBRGTest.java
+++ b/bpmn/MSOInfrastructureBPMN/src/test/java/org/openecomp/mso/bpmn/vcpe/DoCreateAllottedResourceBRGTest.java
@@ -277,7 +277,6 @@ public class DoCreateAllottedResourceBRGTest extends AbstractTestBase {
                variables.put("vni", "BRG");
                variables.put("vgmuxBearerIP", "bearerip");
                variables.put("brgWanMacAddress", "wanmac");
-               variables.put("junitSleepMs", "5");
 
                variables.put("serviceInstanceId", DEC_INST);
                variables.put("parentServiceInstanceId", DEC_PARENT_INST);

diff --git a/bpmn/MSOInfrastructureBPMN/src/test/resources/__files/VCPE/CreateVcpeResCustService/SDNCTopologyQueryTXCCallback.xml b/bpmn/MSOInfrastructureBPMN/src/test/resources/__files/VCPE/CreateVcpeResCustService/SDNCTopologyQueryTXCCallback.xml
index 9b201d9..05583cd 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/test/resources/__files/VCPE/CreateVcpeResCustService/SDNCTopologyQueryTXCCallback.xml
+++ b/bpmn/MSOInfrastructureBPMN/src/test/resources/__files/VCPE/CreateVcpeResCustService/SDNCTopologyQueryTXCCallback.xml
@@ -16,8 +16,8 @@
     </allotted-resource-identifiers>\r
     <tunnelxconn-assignments>\r
        <vni>my-vni</vni>\r
-       <vgmux_bearer_ip>my-bearer-ip</vgmux_bearer_ip>\r
-       <vgmux_lan_ip>my-lan-ip</vgmux_lan_ip>\r
+       <vgmux-bearer-ip>my-bearer-ip</vgmux-bearer-ip>\r
+       <vgmux-lan-ip>my-lan-ip</vgmux-lan-ip>\r
     </tunnelxconn-assignments>\r
 </tunnelxconn-topology>\r
 \r

diff --git a/bpmn/MSOInfrastructureBPMN/src/test/resources/__files/VCPE/DoCreateAllottedResourceTXC/SDNCTopologyQueryCallback.xml b/bpmn/MSOInfrastructureBPMN/src/test/resources/__files/VCPE/DoCreateAllottedResourceTXC/SDNCTopologyQueryCallback.xml
index 9b201d9..05583cd 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/test/resources/__files/VCPE/DoCreateAllottedResourceTXC/SDNCTopologyQueryCallback.xml
+++ b/bpmn/MSOInfrastructureBPMN/src/test/resources/__files/VCPE/DoCreateAllottedResourceTXC/SDNCTopologyQueryCallback.xml
@@ -16,8 +16,8 @@
     </allotted-resource-identifiers>\r
     <tunnelxconn-assignments>\r
        <vni>my-vni</vni>\r
-       <vgmux_bearer_ip>my-bearer-ip</vgmux_bearer_ip>\r
-       <vgmux_lan_ip>my-lan-ip</vgmux_lan_ip>\r
+       <vgmux-bearer-ip>my-bearer-ip</vgmux-bearer-ip>\r
+       <vgmux-lan-ip>my-lan-ip</vgmux-lan-ip>\r
     </tunnelxconn-assignments>\r
 </tunnelxconn-topology>\r
 \r

diff --git a/bpmn/MSOInfrastructureBPMN/src/test/resources/mso.bpmn.urn.properties b/bpmn/MSOInfrastructureBPMN/src/test/resources/mso.bpmn.urn.properties
index aad79b0..325ee3c 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/test/resources/mso.bpmn.urn.properties
+++ b/bpmn/MSOInfrastructureBPMN/src/test/resources/mso.bpmn.urn.properties
@@ -40,6 +40,8 @@ mso.sdnc.timeout.ucpe.async.hours=120
 mso.sdnc.timeout.ucpe.async.minutes=5\r
 mso.workflow.message.endpoint=http://localhost:28080/mso/WorkflowMesssage\r
 mso.workflow.sdncadapter.callback=http://localhost:28080/mso/SDNCAdapterCallbackService\r
+mso.workflow.sdnc.replication.delay=PT0.01S\r
+mso.workflow.aai.distribution.delay=PT0.01S\r
 \r
 mso.catalog.db.endpoint=http://localhost:28090\r
 \r