You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2007/07/03 10:23:16 UTC
svn commit: r552733 -
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java
Author: rajdavies
Date: Tue Jul 3 01:23:15 2007
New Revision: 552733
URL: http://svn.apache.org/viewvc?view=rev&rev=552733
Log:
Do this test properly
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java
Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java?view=diff&rev=552733&r1=552732&r2=552733
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java Tue Jul 3 01:23:15 2007
@@ -78,8 +78,7 @@
}
protected void messageSent() throws Exception{
- if(true)
- return;
+
if(++inflightMessageCount>=failureCount){
inflightMessageCount=0;
Thread.sleep(1000);