svn commit: r1391061 - in /camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx: BatchTransactedConcurrentMultipleConsumerTest.java TransactedConcurrentConsumersTest.java

[sully6768]

Author: sully6768
Date: Thu Sep 27 15:50:47 2012
New Revision: 1391061

URL: http://svn.apache.org/viewvc?rev=1391061&view=rev
Log:
Fixed log message to reflect actual behavior.

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

Modified: 
camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleConsumerTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleConsumerTest.java?rev=1391061&r1=1391060&r2=1391061&view=diff
==============================================================================
--- 
camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleConsumerTest.java
 (original)
+++ 
camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleConsumerTest.java
 Thu Sep 27 15:50:47 2012
@@ -94,7 +94,7 @@ public class BatchTransactedConcurrentMu
                             @Override
                             public void process(Exchange exchange) throws 
Exception {
                                 if (counter.incrementAndGet() == 
MAX_ATTEMPTS_COUNT) {
-                                    log.info("Exchange does not have a retry 
message.  Set the exception and allow the retry.");
+                                    log.info("{} Messages have been processed. 
Failing the exchange to force a rollback of the transaction.", 
MAX_ATTEMPTS_COUNT);
                                     exchange.getOut().setFault(true);
                                 }
                             }

Modified: 
camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConcurrentConsumersTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConcurrentConsumersTest.java?rev=1391061&r1=1391060&r2=1391061&view=diff
==============================================================================
--- 
camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConcurrentConsumersTest.java
 (original)
+++ 
camel/trunk/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConcurrentConsumersTest.java
 Thu Sep 27 15:50:47 2012
@@ -96,7 +96,7 @@ public class TransactedConcurrentConsume
                             public void process(Exchange exchange) throws 
Exception {
                                 int count = counter.incrementAndGet();
                                 if (count == MAX_ATTEMPTS_COUNT) {
-                                    log.info("Exchange does not have a retry 
message.  Set the exception and allow the retry.");
+                                    log.info("{} Messages have been processed. 
Failing the exchange to force a rollback of the transaction.", 
MAX_ATTEMPTS_COUNT);
                                     exchange.getOut().setFault(true);
                                     counter.set(0);
                                 }