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

push out the hang threshold for loaded/slow machines - intermittent failure 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@904444 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2010-01-29 10:07:37 +00:00
parent 98a0f39b34
commit 6205a0f9c8
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2413Test.java
View File

@ -18,7 +18,6 @@ package org.apache.activemq.bugs;
import java.io.File; import java.io.File;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Semaphore; import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
@ -35,6 +34,8 @@ import javax.jms.MessageListener;
import javax.jms.MessageProducer; import javax.jms.MessageProducer;
import javax.jms.Session; import javax.jms.Session;
import junit.framework.Test;
import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.CombinationTestSupport; import org.apache.activemq.CombinationTestSupport;
@ -43,18 +44,11 @@ import org.apache.activemq.broker.region.policy.PolicyEntry;
import org.apache.activemq.broker.region.policy.PolicyMap; import org.apache.activemq.broker.region.policy.PolicyMap;
import org.apache.activemq.broker.region.policy.VMPendingQueueMessageStoragePolicy; 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 { public class AMQ2413Test extends CombinationTestSupport implements MessageListener {
BrokerService broker; BrokerService broker;
private ActiveMQConnectionFactory factory; 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 SEND_COUNT = 10000;
private static final int RECEIVER_THINK_TIME = 1; private static final int RECEIVER_THINK_TIME = 1;
private static final int CONSUMER_COUNT = 1; private static final int CONSUMER_COUNT = 1;