svn commit: r1389621 - /camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerTest.java

[sully6768]

Author: sully6768
Date: Mon Sep 24 22:05:46 2012
New Revision: 1389621

URL: http://svn.apache.org/viewvc?rev=1389621&view=rev
Log:
Document clean up and test fix for BatchTransactions

Modified:
    
camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerTest.java

Modified: 
camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerTest.java?rev=1389621&r1=1389620&r2=1389621&view=diff
==============================================================================
--- 
camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerTest.java
 (original)
+++ 
camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerTest.java
 Mon Sep 24 22:05:46 2012
@@ -46,7 +46,7 @@ public class BatchTransactedTopicConsume
         // We should get two sets of 10 messages.  10 before the rollback and 
10 after the rollback.
         getMockEndpoint("mock:test.before.1").expectedMessageCount(10);
         getMockEndpoint("mock:test.before.2").expectedMessageCount(10);
-        getMockEndpoint("mock:test.after.1").expectedMinimumMessageCount(10);
+        getMockEndpoint("mock:test.after.1").expectedMessageCount(10);
         getMockEndpoint("mock:test.after.2").expectedMessageCount(10);
 
         // Send only 10 messages
@@ -101,7 +101,7 @@ public class BatchTransactedTopicConsume
                                         // Try failing in two places to
                                         // ensure we still get the number of 
messages that
                                         // we expect across the topics
-                                        if (body.endsWith("6")) {
+                                        if (body.endsWith("6") || 
body.endsWith("10")) {
                                             log.info("5th message received.  
Rolling back.");
                                             exchange.getOut().setFault(true);
                                             exchange.getOut().setBody("5th 
message received.  Rolling back.");
@@ -129,7 +129,7 @@ public class BatchTransactedTopicConsume
                                         // Try failing in two places to
                                         // ensure we still get the number of 
messages that
                                         // we expect across the topics
-                                        if (body.endsWith("3") || 
body.endsWith("7")) {
+                                        if (body.endsWith("3") || 
body.endsWith("10")) {
                                             log.info("5th message received.  
Rolling back.");
                                             exchange.getOut().setFault(true);
                                             exchange.getOut().setBody("5th 
message received.  Rolling back.");