[servicecomb-pack] branch SCB-1321 updated: SCB-1321 Modify SagaIntegrationTest await time to 10 seconds

[zhanglei]

This is an automated email from the ASF dual-hosted git repository.

zhanglei pushed a commit to branch SCB-1321
in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git


The following commit(s) were added to refs/heads/SCB-1321 by this push:
     new d23c9a1  SCB-1321 Modify SagaIntegrationTest await time to 10 seconds
d23c9a1 is described below

commit d23c9a1949d3284e24208e80a7731b41d3a8f598
Author: Lei Zhang <zhang...@apache.org>
AuthorDate: Fri Jul 5 16:03:00 2019 +0800

    SCB-1321 Modify SagaIntegrationTest await time to 10 seconds
---
 .../pack/alpha/fsm/SagaIntegrationTest.java        | 24 +++++++++++-----------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git 
a/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/SagaIntegrationTest.java
 
b/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/SagaIntegrationTest.java
index b5b1f29..f43fab9 100644
--- 
a/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/SagaIntegrationTest.java
+++ 
b/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/SagaIntegrationTest.java
@@ -57,7 +57,7 @@ public class SagaIntegrationTest {
       sagaEventBus.post(event);
     });
 
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getSagaData(globalTxId);
       if(sagaData != null){
         return sagaData.getLastState() == SagaActorState.COMMITTED
@@ -81,7 +81,7 @@ public class SagaIntegrationTest {
       sagaEventBus.post(event);
     });
 
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getSagaData(globalTxId);
       if(sagaData != null){
         return sagaData.getLastState() == SagaActorState.COMPENSATED
@@ -104,7 +104,7 @@ public class SagaIntegrationTest {
       sagaEventBus.post(event);
     });
 
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getSagaData(globalTxId);
       if(sagaData != null){
         return sagaData.getLastState() == SagaActorState.COMPENSATED
@@ -129,7 +129,7 @@ public class SagaIntegrationTest {
       sagaEventBus.post(event);
     });
 
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getSagaData(globalTxId);
       if(sagaData != null){
         return sagaData.getLastState() == SagaActorState.COMPENSATED
@@ -155,7 +155,7 @@ public class SagaIntegrationTest {
         sagaEventBus.post(event);
       });
 
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getSagaData(globalTxId);
       if(sagaData != null){
         return sagaData.getLastState() == SagaActorState.COMPENSATED
@@ -181,7 +181,7 @@ public class SagaIntegrationTest {
       sagaEventBus.post(event);
     });
 
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getSagaData(globalTxId);
       if(sagaData != null){
         return sagaData.getLastState() == SagaActorState.COMPENSATED
@@ -207,7 +207,7 @@ public class SagaIntegrationTest {
       sagaEventBus.post(event);
     });
 
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getSagaData(globalTxId);
       if(sagaData != null){
         return sagaData.getLastState() == SagaActorState.COMPENSATED
@@ -233,7 +233,7 @@ public class SagaIntegrationTest {
       sagaEventBus.post(event);
     });
 
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getSagaData(globalTxId);
       if(sagaData != null){
         return sagaData.getLastState() == SagaActorState.SUSPENDED
@@ -260,7 +260,7 @@ public class SagaIntegrationTest {
       sagaEventBus.post(event);
     });
 
-    await().atMost(timeout+1, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getSagaData(globalTxId);
       if(sagaData != null){
         return sagaData.getLastState() == SagaActorState.SUSPENDED
@@ -286,7 +286,7 @@ public class SagaIntegrationTest {
       sagaEventBus.post(event);
     });
 
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getSagaData(globalTxId);
       if(sagaData != null){
         return sagaData.getLastState() == SagaActorState.COMMITTED
@@ -312,7 +312,7 @@ public class SagaIntegrationTest {
       sagaEventBus.post(event);
     });
 
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getSagaData(globalTxId);
       if(sagaData != null){
         return sagaData.getLastState() == SagaActorState.COMMITTED
@@ -338,7 +338,7 @@ public class SagaIntegrationTest {
       sagaEventBus.post(event);
     });
 
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getSagaData(globalTxId);
       if(sagaData != null){
         return sagaData.getLastState() == SagaActorState.COMPENSATED