Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix assertion error messages so that indicate an actual error. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1187577 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2011-10-21 22:18:28 +00:00
parent c273cab44a
commit 06611d9c19
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java
View File

@ -17,7 +17,6 @@
package org.apache.activemq.transport.failover; package org.apache.activemq.transport.failover;
import junit.framework.Test; import junit.framework.Test;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.AutoFailTestSupport; import org.apache.activemq.AutoFailTestSupport;
import org.apache.activemq.TestSupport; import org.apache.activemq.TestSupport;
@ -576,12 +575,12 @@ public class FailoverTransactionTest extends TestSupport {
session.commit(); session.commit();
for (int i = 0; i < count - 1; i++) { 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(); session.commit();
connection.close(); 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 { public void testFailoverConsumerAckLost() throws Exception {