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

compaction or gc can effect this test - make it more tolerant and dumpthreads on error so we can validate

This commit is contained in:
gtully 2014-03-13 16:27:35 +00:00
parent 7d194a1e7f
commit caae68a1ba
1 changed files with 10 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
activemq-unit-tests/src/test/java/org/apache/activemq/usecases/MemoryLimitTest.java
View File

@ -16,16 +16,12 @@
*/ */
package org.apache.activemq.usecases; package org.apache.activemq.usecases;
import java.util.ArrayList; import java.util.Arrays;
import java.util.Collection;
import java.util.List;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.Message; import javax.jms.Message;
import javax.jms.MessageConsumer; import javax.jms.MessageConsumer;
import javax.jms.Queue; import javax.jms.Queue;
import javax.jms.Session; import javax.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.TestSupport; import org.apache.activemq.TestSupport;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
@ -51,22 +47,12 @@ public class MemoryLimitTest extends TestSupport {
final String payload = new String(new byte[10 * 1024]); //10KB final String payload = new String(new byte[10 * 1024]); //10KB
protected BrokerService broker; protected BrokerService broker;
private final TestSupport.PersistenceAdapterChoice persistenceAdapterChoice; @Parameterized.Parameter
public TestSupport.PersistenceAdapterChoice persistenceAdapterChoice;
@Parameterized.Parameters @Parameterized.Parameters(name="{0}")
public static Collection<TestSupport.PersistenceAdapterChoice[]> getTestParameters() { public static Iterable<Object[]> getTestParameters() {
TestSupport.PersistenceAdapterChoice[] kahaDb = {TestSupport.PersistenceAdapterChoice.KahaDB}; return Arrays.asList(new Object[][]{{TestSupport.PersistenceAdapterChoice.KahaDB}, {PersistenceAdapterChoice.LevelDB}, {PersistenceAdapterChoice.JDBC}});
TestSupport.PersistenceAdapterChoice[] levelDb = {TestSupport.PersistenceAdapterChoice.LevelDB};
TestSupport.PersistenceAdapterChoice[] jdbc = {TestSupport.PersistenceAdapterChoice.JDBC};
List<TestSupport.PersistenceAdapterChoice[]> choices = new ArrayList<TestSupport.PersistenceAdapterChoice[]>();
choices.add(kahaDb);
choices.add(levelDb);
choices.add(jdbc);
return choices;
}
public MemoryLimitTest(TestSupport.PersistenceAdapterChoice choice) {
this.persistenceAdapterChoice = choice;
} }
protected BrokerService createBroker() throws Exception { protected BrokerService createBroker() throws Exception {
@ -155,7 +141,10 @@ public class MemoryLimitTest extends TestSupport {
// let's make sure we can consume all messages // let's make sure we can consume all messages
for (int i = 1; i < 2000; i++) { for (int i = 1; i < 2000; i++) {
msg = consumer.receive(1000); msg = consumer.receive(5000);
if (msg == null) {
dumpAllThreads("NoMessage");
}
assertNotNull("Didn't receive message " + i, msg); assertNotNull("Didn't receive message " + i, msg);
msg.acknowledge(); msg.acknowledge();
} }