aboutsummaryrefslogtreecommitdiffstats
path: root/bpmn/MSOCommonBPMN/src/test/java/org/openecomp/mso/bpmn/common/ReceiveWorkflowMessageTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'bpmn/MSOCommonBPMN/src/test/java/org/openecomp/mso/bpmn/common/ReceiveWorkflowMessageTest.java')
-rw-r--r--bpmn/MSOCommonBPMN/src/test/java/org/openecomp/mso/bpmn/common/ReceiveWorkflowMessageTest.java29
1 files changed, 15 insertions, 14 deletions
diff --git a/bpmn/MSOCommonBPMN/src/test/java/org/openecomp/mso/bpmn/common/ReceiveWorkflowMessageTest.java b/bpmn/MSOCommonBPMN/src/test/java/org/openecomp/mso/bpmn/common/ReceiveWorkflowMessageTest.java
index a806515974..64b8ba53b7 100644
--- a/bpmn/MSOCommonBPMN/src/test/java/org/openecomp/mso/bpmn/common/ReceiveWorkflowMessageTest.java
+++ b/bpmn/MSOCommonBPMN/src/test/java/org/openecomp/mso/bpmn/common/ReceiveWorkflowMessageTest.java
@@ -17,7 +17,7 @@
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-
+
package org.openecomp.mso.bpmn.common;
import static org.junit.Assert.assertEquals;
@@ -53,9 +53,9 @@ public class ReceiveWorkflowMessageTest extends WorkflowTest {
" \"eventType\": \"UCPE-ACTIVATION\"," + EOL +
" \"eventCorrelatorType\": \"UCPE-HOST-NAME\"," + EOL +
" \"eventCorrelator\": \"((CORRELATOR))\"," + EOL +
- " \"params\": {\"entry\":[" + EOL +
- " {\"key\": \"success-indicator\", \"value\":\"Y\"}" + EOL +
- " ]}" +EOL +
+ " \"params\": {" + EOL +
+ " \"success-indicator\":\"Y\"" + EOL +
+ " }" +EOL +
" }" + EOL +
"}" + EOL);
@@ -65,10 +65,10 @@ public class ReceiveWorkflowMessageTest extends WorkflowTest {
" \"eventType\": \"UCPE-ACTIVATION\"," + EOL +
" \"eventCorrelatorType\": \"UCPE-HOST-NAME\"," + EOL +
" \"eventCorrelator\": \"((CORRELATOR))\"," + EOL +
- " \"params\": {\"entry\":[" + EOL +
- " {\"key\": \"success-indicator\", \"value\":\"N\"}" + EOL +
- " {\"key\": \"error-message\", \"value\":\"SOMETHING BAD HAPPENED\"}" + EOL +
- " ]}" +EOL +
+ " \"params\": {" + EOL +
+ " \"success-indicator\":\"N\"," + EOL +
+ " \"error-message\":\"SOMETHING BAD HAPPENED\"" + EOL +
+ " }" +EOL +
" }" + EOL +
"}" + EOL);
}
@@ -81,7 +81,7 @@ public class ReceiveWorkflowMessageTest extends WorkflowTest {
"subprocess/ReceiveWorkflowMessage.bpmn"
})
public void happyPath() throws Exception {
-
+
logStart();
String businessKey = UUID.randomUUID().toString();
@@ -100,7 +100,7 @@ public class ReceiveWorkflowMessageTest extends WorkflowTest {
System.out.println("Response:\n" + response);
assertTrue(response.contains("\"SDNCEvent\""));
assertTrue((boolean)getVariableFromHistory(businessKey, "RCVWFMSG_SuccessIndicator"));
-
+
logEnd();
}
@@ -112,22 +112,23 @@ public class ReceiveWorkflowMessageTest extends WorkflowTest {
"subprocess/ReceiveWorkflowMessage.bpmn"
})
public void timeout() throws Exception {
+
logStart();
String businessKey = UUID.randomUUID().toString();
Map<String, Object> variables = new HashMap<>();
variables.put("mso-request-id", "dffbae0e-5588-4bd6-9749-b0f0adb52312");
variables.put("isDebugLogEnabled", "true");
- variables.put("RCVWFMSG_timeout", "PT0.1S");
+ variables.put("RCVWFMSG_timeout", "PT5S");
variables.put("RCVWFMSG_messageType", "SDNCAEvent");
variables.put("RCVWFMSG_correlator", "USOSTCDALTX0101UJZZ31");
invokeSubProcess("ReceiveWorkflowMessage", businessKey, variables);
// No injection
-
+
waitForProcessEnd(businessKey, 10000);
-
+
// There is no response from SDNC, so the flow doesn't set WorkflowResponse.
String response = (String) getVariableFromHistory(businessKey, "WorkflowResponse");
assertNull(response);
@@ -136,7 +137,7 @@ public class ReceiveWorkflowMessageTest extends WorkflowTest {
System.out.println(wfe.toString());
assertEquals("Receive Workflow Message Timeout Error", wfe.getErrorMessage());
assertFalse((boolean)getVariableFromHistory(businessKey, "RCVWFMSG_SuccessIndicator"));
-
+
logEnd();
}
}