[prev in list] [next in list] [prev in thread] [next in thread]
List: activemq-commits
Subject: svn commit: r1187577 -
From: tabish () apache ! org
Date: 2011-10-21 22:18:28
Message-ID: 20111021221828.B2C98238888F () eris ! apache ! org
[Download RAW message or body]
Author: tabish
Date: Fri Oct 21 22:18:28 2011
New Revision: 1187577
URL: http://svn.apache.org/viewvc?rev=1187577&view=rev
Log:
Fix assertion error messages so that indicate an actual error.
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java
Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apach \
e/activemq/transport/failover/FailoverTransactionTest.java?rev=1187577&r1=1187576&r2=1187577&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java \
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java \
Fri Oct 21 22:18:28 2011 @@ -17,7 +17,6 @@
package org.apache.activemq.transport.failover;
import junit.framework.Test;
-import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.AutoFailTestSupport;
import org.apache.activemq.TestSupport;
@@ -576,12 +575,12 @@ public class FailoverTransactionTest ext
session.commit();
for (int i = 0; i < count - 1; i++) {
- assertNotNull("we got all the message: " + count, \
consumer.receive(20000)); + assertNotNull("Failed to get message: " + \
count, consumer.receive(20000)); }
session.commit();
connection.close();
- assertTrue("connectionconsumer got a message", \
connectionConsumerGotOne.await(10, TimeUnit.SECONDS)); + \
assertTrue("connectionconsumer did not get a message", \
connectionConsumerGotOne.await(10, TimeUnit.SECONDS)); }
public void testFailoverConsumerAckLost() throws Exception {
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic