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

add some additional trace debug to investigate linear store usage, this test has been failing in ci for the past 7 builds but work ok locally. This additional trace will help diagnose

This commit is contained in:
gtully 2015-11-30 14:03:48 +00:00
parent cfb4ca9f54
commit 144b711a9a
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java
View File

@ -33,6 +33,8 @@ 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;
import org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter; import org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
import org.apache.activemq.store.kahadb.MessageDatabase;
import org.apache.log4j.Level;
import org.junit.After; import org.junit.After;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
@ -103,6 +105,9 @@ public class TransactedStoreUsageSuspendResumeTest {
@Before @Before
public void setup() throws Exception { public void setup() throws Exception {
// investigate liner gc issue - store usage not getting released
org.apache.log4j.Logger.getLogger(MessageDatabase.class).setLevel(Level.TRACE);
broker = new BrokerService(); broker = new BrokerService();
broker.setDeleteAllMessagesOnStartup(true); broker.setDeleteAllMessagesOnStartup(true);
broker.setPersistent(true); broker.setPersistent(true);
@ -141,8 +146,13 @@ public class TransactedStoreUsageSuspendResumeTest {
sendExecutor.shutdown(); sendExecutor.shutdown();
sendExecutor.awaitTermination(5, TimeUnit.MINUTES); sendExecutor.awaitTermination(5, TimeUnit.MINUTES);
boolean allMessagesReceived = messagesReceivedCountDown.await(10, TimeUnit.MINUTES); boolean allMessagesReceived = messagesReceivedCountDown.await(5, TimeUnit.MINUTES);
if (!allMessagesReceived) { if (!allMessagesReceived) {
LOG.info("Giving up - not all received on time...");
LOG.info("System Mem Usage: " + broker.getSystemUsage().getMemoryUsage());
LOG.info("System Store Usage: " +broker.getSystemUsage().getStoreUsage());
LOG.info("Producer sent: " + messagesSentCountDown.getCount());
LOG.info("Consumer remaining to receive: " + messagesReceivedCountDown.getCount());
TestSupport.dumpAllThreads("StuckConsumer!"); TestSupport.dumpAllThreads("StuckConsumer!");
} }
assertTrue("Got all messages: " + messagesReceivedCountDown, allMessagesReceived); assertTrue("Got all messages: " + messagesReceivedCountDown, allMessagesReceived);