for integration tests, in the runFlow method check for responseEvent.…

…getMessage().getExceptionPayload() != null and if true throw an exception so that the test fails
genjosanzo · Apr 11, 2012 · 12e6415 · 12e6415
1 parent d85c1c7
commit 12e6415
Show file tree

Hide file tree

Showing 10 changed files with 32 additions and 4 deletions.
diff --git a/.../it/bean-inject-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java b/.../it/bean-inject-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java
@@ -34,6 +34,9 @@ protected <T> void runFlow(String flowName) throws Exception {
         Flow flow = lookupFlowConstruct(flowName);
         MuleEvent event = AbstractMuleTestCase.getTestEvent(payload);
         MuleEvent responseEvent = flow.process(event);
+        if(responseEvent.getMessage().getExceptionPayload() != null) {
+            throw new Exception(responseEvent.getMessage().getExceptionPayload().getRootException());
+        }
     }
 
     protected <T> void runFlow(String flowName, T expect) throws Exception {

diff --git a/...s/it/collection-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java b/...s/it/collection-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java
@@ -29,11 +29,14 @@ protected Flow lookupFlowConstruct(String name) {
         return (Flow) AbstractMuleTestCase.muleContext.getRegistry().lookupFlowConstruct(name);
     }
 
-    protected void runFlow(String flowName) throws Exception {
+    protected <T> void runFlow(String flowName) throws Exception {
         String payload = EMPTY_PAYLOAD;
         Flow flow = lookupFlowConstruct(flowName);
         MuleEvent event = AbstractMuleTestCase.getTestEvent(payload);
         MuleEvent responseEvent = flow.process(event);
+        if(responseEvent.getMessage().getExceptionPayload() != null) {
+            throw new Exception(responseEvent.getMessage().getExceptionPayload().getRootException());
+        }
     }
 
     protected <T> void runFlow(String flowName, T expect) throws Exception {

diff --git a/...ts/it/connector-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java b/...ts/it/connector-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java
@@ -29,13 +29,14 @@ protected Flow lookupFlowConstruct(String name) {
         return (Flow) AbstractMuleTestCase.muleContext.getRegistry().lookupFlowConstruct(name);
     }
 
-    protected <T> T runFlow(String flowName) throws Exception {
+    protected <T> void runFlow(String flowName) throws Exception {
         String payload = EMPTY_PAYLOAD;
         Flow flow = lookupFlowConstruct(flowName);
         MuleEvent event = AbstractMuleTestCase.getTestEvent(payload);
         MuleEvent responseEvent = flow.process(event);
-
-        return (T) responseEvent.getMessage().getPayload();
+        if(responseEvent.getMessage().getExceptionPayload() != null) {
+            throw new Exception(responseEvent.getMessage().getExceptionPayload().getRootException());
+        }
     }
 
     protected <T> void runFlow(String flowName, T expect) throws Exception {

diff --git a/...ation-tests/it/date-integration-test/src/test/java/org/mule/devkit/it/DateModuleTest.java b/...ation-tests/it/date-integration-test/src/test/java/org/mule/devkit/it/DateModuleTest.java
@@ -51,6 +51,9 @@ private Flow lookupFlowConstruct(String name) {
     private Object runFlow(String flowName, String payload) throws Exception {
         Flow flow = lookupFlowConstruct(flowName);
         MuleEvent event = AbstractMuleTestCase.getTestEvent(payload);
+        if(event.getMessage().getExceptionPayload() != null) {
+            throw new Exception(event.getMessage().getExceptionPayload().getRootException());
+        }
         return flow.process(event).getMessage().getPayload();
     }
 }
diff --git a/...pting-processor-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java b/...pting-processor-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java
@@ -34,6 +34,9 @@ protected <T> void runFlow(String flowName) throws Exception {
         Flow flow = lookupFlowConstruct(flowName);
         MuleEvent event = AbstractMuleTestCase.getTestEvent(payload);
         MuleEvent responseEvent = flow.process(event);
+        if(responseEvent.getMessage().getExceptionPayload() != null) {
+            throw new Exception(responseEvent.getMessage().getExceptionPayload().getRootException());
+        }
     }
 
     protected <T> void runFlow(String flowName, T expect) throws Exception {

diff --git a/...ts/it/lifecycle-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java b/...ts/it/lifecycle-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java
@@ -34,6 +34,9 @@ protected <T> void runFlow(String flowName) throws Exception {
         Flow flow = lookupFlowConstruct(flowName);
         MuleEvent event = AbstractMuleTestCase.getTestEvent(payload);
         MuleEvent responseEvent = flow.process(event);
+        if(responseEvent.getMessage().getExceptionPayload() != null) {
+            throw new Exception(responseEvent.getMessage().getExceptionPayload().getRootException());
+        }
     }
 
     protected <T> void runFlow(String flowName, T expect) throws Exception {

diff --git a/...ested-processor-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java b/...ested-processor-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java
@@ -34,6 +34,9 @@ protected <T> void runFlow(String flowName) throws Exception {
         Flow flow = lookupFlowConstruct(flowName);
         MuleEvent event = AbstractMuleTestCase.getTestEvent(payload);
         MuleEvent responseEvent = flow.process(event);
+        if(responseEvent.getMessage().getExceptionPayload() != null) {
+            throw new Exception(responseEvent.getMessage().getExceptionPayload().getRootException());
+        }
     }
 
     protected <T> void runFlow(String flowName, T expect) throws Exception {

diff --git a/...utbound-headers-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java b/...utbound-headers-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java
@@ -34,6 +34,9 @@ protected <T> void runFlow(String flowName) throws Exception {
         Flow flow = lookupFlowConstruct(flowName);
         MuleEvent event = AbstractMuleTestCase.getTestEvent(payload);
         MuleEvent responseEvent = flow.process(event);
+        if(responseEvent.getMessage().getExceptionPayload() != null) {
+            throw new Exception(responseEvent.getMessage().getExceptionPayload().getRootException());
+        }
     }
 
     protected <T> void runFlow(String flowName, T expect) throws Exception {

diff --git a/...n-tests/it/pool-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java b/...n-tests/it/pool-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java
@@ -34,6 +34,9 @@ protected <T> void runFlow(String flowName) throws Exception {
         Flow flow = lookupFlowConstruct(flowName);
         MuleEvent event = AbstractMuleTestCase.getTestEvent(payload);
         MuleEvent responseEvent = flow.process(event);
+        if(responseEvent.getMessage().getExceptionPayload() != null) {
+            throw new Exception(responseEvent.getMessage().getExceptionPayload().getRootException());
+        }
     }
 
     protected <T> void runFlow(String flowName, T expect) throws Exception {

diff --git a/...tests/it/source-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java b/...tests/it/source-integration-test/src/test/java/org/mule/devkit/it/AbstractModuleTest.java
@@ -34,6 +34,9 @@ protected <T> void runFlow(String flowName) throws Exception {
         Flow flow = lookupFlowConstruct(flowName);
         MuleEvent event = AbstractMuleTestCase.getTestEvent(payload);
         MuleEvent responseEvent = flow.process(event);
+        if(responseEvent.getMessage().getExceptionPayload() != null) {
+            throw new Exception(responseEvent.getMessage().getExceptionPayload().getRootException());
+        }
     }
 
     protected <T> void runFlow(String flowName, T expect) throws Exception {