You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2009/07/22 13:29:57 UTC

svn commit: r796673 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2102Test.java

Author: gtully
Date: Wed Jul 22 11:29:56 2009
New Revision: 796673

URL: http://svn.apache.org/viewvc?rev=796673&view=rev
Log:
ensure a hang does not block full test run to determine if hang can be isolated

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2102Test.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2102Test.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2102Test.java?rev=796673&r1=796672&r2=796673&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2102Test.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2102Test.java Wed Jul 22 11:29:56 2009
@@ -37,16 +37,15 @@
 import javax.jms.TemporaryQueue;
 import javax.jms.TextMessage;
 
-import junit.framework.TestCase;
-
 import org.apache.activemq.ActiveMQConnection;
 import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.CombinationTestSupport;
 import org.apache.activemq.RedeliveryPolicy;
 import org.apache.activemq.broker.BrokerService;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-public class AMQ2102Test extends TestCase implements UncaughtExceptionHandler {
+public class AMQ2102Test extends CombinationTestSupport implements UncaughtExceptionHandler {
        
     final static int MESSAGE_COUNT = 12120;
     final static int NUM_CONSUMERS = 10;
@@ -442,7 +441,7 @@
     String masterUrl;
 
     public void setUp() throws Exception {
-        
+        setAutoFail(true);
         master.setBrokerName("Master");
         master.addConnector("tcp://localhost:0");
         master.deleteAllMessages();