You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by su...@apache.org on 2012/09/25 00:05:46 UTC
svn commit: r1389621 -
/camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerTest.java
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.");