[jboss-svn-commits] JBL Code SVN: r10260 - labs/jbossesb/trunk/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/message.

[jboss-svn-commits at lists.jboss.org]

Author: kevin.conner at jboss.com
Date: 2007-03-16 08:31:29 -0400 (Fri, 16 Mar 2007)
New Revision: 10260

Modified:
   labs/jbossesb/trunk/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipelineUnitTest.java
Log:
Updated to check for repeat invocation of pipeline: JBESB-463

Modified: labs/jbossesb/trunk/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipelineUnitTest.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipelineUnitTest.java	2007-03-16 12:24:28 UTC (rev 10259)
+++ labs/jbossesb/trunk/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipelineUnitTest.java	2007-03-16 12:31:29 UTC (rev 10260)
@@ -68,6 +68,12 @@
         checkOrder(MockActionInfo.getSuccessList(), 4, 2, 0) ;
         checkOrder(MockActionInfo.getExceptionList()) ;
         
+        final boolean secondResult = pipeline.process(MessageFactory.getInstance().getMessage()) ;
+        assertTrue("Pipeline process failure", secondResult) ;
+        checkOrder(MockActionInfo.getProcessList(), 0, 2, 4, 0, 2, 4) ;
+        checkOrder(MockActionInfo.getSuccessList(), 4, 2, 0, 4, 2, 0) ;
+        checkOrder(MockActionInfo.getExceptionList()) ;
+        
         pipeline.destroy() ;
         checkOrder(MockActionInfo.getDestroyList(), 4, 2, 0) ;
     }
@@ -93,7 +99,13 @@
         checkOrder(MockActionInfo.getProcessList(), 0, 2) ;
         checkOrder(MockActionInfo.getSuccessList()) ;
         checkOrder(MockActionInfo.getExceptionList(), 2, 0) ;
-        
+
+        final boolean secondResult = pipeline.process(MessageFactory.getInstance().getMessage()) ;
+        assertFalse("Pipeline process succeeded", secondResult) ;
+        checkOrder(MockActionInfo.getProcessList(), 0, 2, 0, 2) ;
+        checkOrder(MockActionInfo.getSuccessList()) ;
+        checkOrder(MockActionInfo.getExceptionList(), 2, 0, 2, 0) ;
+
         pipeline.destroy() ;
         checkOrder(MockActionInfo.getDestroyList(), 4, 2, 0) ;
     }
@@ -122,6 +134,12 @@
         checkOrder(MockActionInfo.getSuccessList(), 7, 4, 3, 0) ;
         checkOrder(MockActionInfo.getExceptionList()) ;
         
+        final boolean secondResult = pipeline.process(MessageFactory.getInstance().getMessage()) ;
+        assertTrue("Pipeline process failure", secondResult) ;
+        checkOrder(MockActionInfo.getProcessList(), 0, 2, 4, 6, 7, 0, 2, 4, 6, 7) ;
+        checkOrder(MockActionInfo.getSuccessList(), 7, 4, 3, 0, 7, 4, 3, 0) ;
+        checkOrder(MockActionInfo.getExceptionList()) ;
+        
         pipeline.destroy() ;
         checkOrder(MockActionInfo.getDestroyList(), 6, 4, 2, 0) ;
     }
@@ -150,6 +168,12 @@
         checkOrder(MockActionInfo.getSuccessList()) ;
         checkOrder(MockActionInfo.getExceptionList(), 5, 2, 0) ;
         
+        final boolean secondResult = pipeline.process(MessageFactory.getInstance().getMessage()) ;
+        assertFalse("Pipeline process succeeded", secondResult) ;
+        checkOrder(MockActionInfo.getProcessList(), 0, 2, 4, 0, 2, 4) ;
+        checkOrder(MockActionInfo.getSuccessList()) ;
+        checkOrder(MockActionInfo.getExceptionList(), 5, 2, 0, 5, 2, 0) ;
+        
         pipeline.destroy() ;
         checkOrder(MockActionInfo.getDestroyList(), 6, 4, 2, 0) ;
     }
@@ -178,6 +202,12 @@
         checkOrder(MockActionInfo.getSuccessList(), 7, 2) ;
         checkOrder(MockActionInfo.getExceptionList()) ;
         
+        final boolean secondResult = pipeline.process(MessageFactory.getInstance().getMessage()) ;
+        assertTrue("Pipeline process failure", secondResult) ;
+        checkOrder(MockActionInfo.getProcessList(), 0, 2, 4, 6, 7, 0, 2, 4, 6, 7) ;
+        checkOrder(MockActionInfo.getSuccessList(), 7, 2, 7, 2) ;
+        checkOrder(MockActionInfo.getExceptionList()) ;
+        
         pipeline.destroy() ;
         checkOrder(MockActionInfo.getDestroyList(), 6, 4, 2, 0) ;
     }
@@ -206,6 +236,12 @@
         checkOrder(MockActionInfo.getSuccessList()) ;
         checkOrder(MockActionInfo.getExceptionList(), 5) ;
         
+        final boolean secondResult = pipeline.process(MessageFactory.getInstance().getMessage()) ;
+        assertFalse("Pipeline process succeeded", secondResult) ;
+        checkOrder(MockActionInfo.getProcessList(), 0, 2, 4, 0, 2, 4) ;
+        checkOrder(MockActionInfo.getSuccessList()) ;
+        checkOrder(MockActionInfo.getExceptionList(), 5, 5) ;
+        
         pipeline.destroy() ;
         checkOrder(MockActionInfo.getDestroyList(), 6, 4, 2, 0) ;
     }