mirror of https://github.com/apache/activemq.git
Bumped up test timeouts because of CI failures, also cleaned up imports
This commit is contained in:
parent
c027552035
commit
fa6aaf9360
|
@ -84,7 +84,7 @@ public class QueueSubscriptionTest extends JmsMultipleClientsTestSupport {
|
|||
assertTotalMessagesReceived(messageCount * producerCount);
|
||||
}
|
||||
|
||||
@Test(timeout = 60 * 1000)
|
||||
@Test(timeout = 2 * 60 * 1000)
|
||||
public void testOneProducerTwoConsumersLargeMessagesOnePrefetch() throws Exception {
|
||||
consumerCount = 2;
|
||||
producerCount = 1;
|
||||
|
@ -136,7 +136,7 @@ public class QueueSubscriptionTest extends JmsMultipleClientsTestSupport {
|
|||
assertTotalMessagesReceived(messageCount * producerCount);
|
||||
}
|
||||
|
||||
@Test(timeout = 60 * 1000)
|
||||
@Test(timeout = 2 * 60 * 1000)
|
||||
public void testManyProducersManyConsumers() throws Exception {
|
||||
consumerCount = 200;
|
||||
producerCount = 50;
|
||||
|
|
|
@ -16,11 +16,6 @@
|
|||
*/
|
||||
package org.apache.activemq.broker.policy;
|
||||
|
||||
import javax.jms.Connection;
|
||||
import javax.jms.Destination;
|
||||
import javax.jms.MessageConsumer;
|
||||
import javax.jms.Session;
|
||||
|
||||
import org.apache.activemq.broker.BrokerService;
|
||||
import org.apache.activemq.broker.QueueSubscriptionTest;
|
||||
import org.apache.activemq.broker.region.policy.PolicyEntry;
|
||||
|
@ -30,6 +25,11 @@ import org.junit.Test;
|
|||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.BlockJUnit4ClassRunner;
|
||||
|
||||
import javax.jms.Connection;
|
||||
import javax.jms.Destination;
|
||||
import javax.jms.MessageConsumer;
|
||||
import javax.jms.Session;
|
||||
|
||||
@RunWith(BlockJUnit4ClassRunner.class)
|
||||
public class RoundRobinDispatchPolicyTest extends QueueSubscriptionTest {
|
||||
|
||||
|
|
|
@ -16,10 +16,6 @@
|
|||
*/
|
||||
package org.apache.activemq.broker.policy;
|
||||
|
||||
import java.util.Iterator;
|
||||
|
||||
import javax.jms.MessageConsumer;
|
||||
|
||||
import org.apache.activemq.broker.BrokerService;
|
||||
import org.apache.activemq.broker.QueueSubscriptionTest;
|
||||
import org.apache.activemq.broker.region.policy.FixedCountSubscriptionRecoveryPolicy;
|
||||
|
@ -31,7 +27,11 @@ import org.junit.Test;
|
|||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.BlockJUnit4ClassRunner;
|
||||
|
||||
import static org.junit.Assert.*;
|
||||
import javax.jms.MessageConsumer;
|
||||
import java.util.Iterator;
|
||||
|
||||
import static org.junit.Assert.assertEquals;
|
||||
import static org.junit.Assert.fail;
|
||||
|
||||
@RunWith(BlockJUnit4ClassRunner.class)
|
||||
public class SimpleDispatchPolicyTest extends QueueSubscriptionTest {
|
||||
|
|
Loading…
Reference in New Issue