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 2010/01/29 11:07:39 UTC
svn commit: r904444 -
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2413Test.java
Author: gtully
Date: Fri Jan 29 10:07:37 2010
New Revision: 904444
URL: http://svn.apache.org/viewvc?rev=904444&view=rev
Log:
push out the hang threshold for loaded/slow machines - intermittent failure
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2413Test.java
Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2413Test.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2413Test.java?rev=904444&r1=904443&r2=904444&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2413Test.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2413Test.java Fri Jan 29 10:07:37 2010
@@ -18,7 +18,6 @@
import java.io.File;
import java.util.ArrayList;
-import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
@@ -35,6 +34,8 @@
import javax.jms.MessageProducer;
import javax.jms.Session;
+import junit.framework.Test;
+
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.CombinationTestSupport;
@@ -43,18 +44,11 @@
import org.apache.activemq.broker.region.policy.PolicyMap;
import org.apache.activemq.broker.region.policy.VMPendingQueueMessageStoragePolicy;
-import junit.framework.Test;
-import junit.framework.TestCase;
-
-/**
- * An AMQ-1282 Test
- *
- */
public class AMQ2413Test extends CombinationTestSupport implements MessageListener {
BrokerService broker;
private ActiveMQConnectionFactory factory;
- private static final int HANG_THRESHOLD = 5;
+ private static final int HANG_THRESHOLD = 30;
private static final int SEND_COUNT = 10000;
private static final int RECEIVER_THINK_TIME = 1;
private static final int CONSUMER_COUNT = 1;