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

Avoid Class cast exception in test case. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1418706 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2012-12-08 16:46:11 +00:00
parent 77a679b03f
commit c65c25ddb6
2 changed files with 30 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
activemq-core/src/test/java/org/apache/activemq/usecases/DurableSubsOfflineSelectorConcurrentConsumeIndexUseTest.java
View File

@ -31,6 +31,7 @@ import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerFactory; import org.apache.activemq.broker.BrokerFactory;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.command.ActiveMQTopic; import org.apache.activemq.command.ActiveMQTopic;
import org.apache.activemq.store.PersistenceAdapter;
import org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter; import org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
import org.apache.activemq.store.kahadb.KahaDBStore; import org.apache.activemq.store.kahadb.KahaDBStore;
import org.apache.activemq.util.Wait; import org.apache.activemq.util.Wait;
@ -200,18 +201,21 @@ public class DurableSubsOfflineSelectorConcurrentConsumeIndexUseTest extends org
session.close(); session.close();
con.close(); con.close();
final KahaDBStore store = ((KahaDBPersistenceAdapter) broker.getPersistenceAdapter()).getStore(); PersistenceAdapter persistenceAdapter = broker.getPersistenceAdapter();
LOG.info("Store page count: " + store.getPageFile().getPageCount()); if( persistenceAdapter instanceof KahaDBPersistenceAdapter) {
LOG.info("Store free page count: " + store.getPageFile().getFreePageCount()); final KahaDBStore store = ((KahaDBPersistenceAdapter) persistenceAdapter).getStore();
LOG.info("Store page in-use: " + (store.getPageFile().getPageCount() - store.getPageFile().getFreePageCount())); LOG.info("Store page count: " + store.getPageFile().getPageCount());
LOG.info("Store free page count: " + store.getPageFile().getFreePageCount());
LOG.info("Store page in-use: " + (store.getPageFile().getPageCount() - store.getPageFile().getFreePageCount()));
assertTrue("no leak of pages, always use just 10", Wait.waitFor(new Wait.Condition() { assertTrue("no leak of pages, always use just 10", Wait.waitFor(new Wait.Condition() {
@Override @Override
public boolean isSatisified() throws Exception { public boolean isSatisified() throws Exception {
return 10 == store.getPageFile().getPageCount() - return 10 == store.getPageFile().getPageCount() -
store.getPageFile().getFreePageCount(); store.getPageFile().getFreePageCount();
} }
}, TimeUnit.SECONDS.toMillis(10))); }, TimeUnit.SECONDS.toMillis(10)));
}
} }
private void waitFor(final Listener listener, final int count) throws Exception { private void waitFor(final Listener listener, final int count) throws Exception {

26
activemq-core/src/test/java/org/apache/activemq/usecases/DurableSubsOfflineSelectorIndexUseTest.java
View File

@ -30,6 +30,7 @@ import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerFactory; import org.apache.activemq.broker.BrokerFactory;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.command.ActiveMQTopic; import org.apache.activemq.command.ActiveMQTopic;
import org.apache.activemq.store.PersistenceAdapter;
import org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter; import org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
import org.apache.activemq.store.kahadb.KahaDBStore; import org.apache.activemq.store.kahadb.KahaDBStore;
import org.apache.activemq.util.Wait; import org.apache.activemq.util.Wait;
@ -176,18 +177,21 @@ public class DurableSubsOfflineSelectorIndexUseTest extends org.apache.activemq.
session.close(); session.close();
con.close(); con.close();
final KahaDBStore store = ((KahaDBPersistenceAdapter) broker.getPersistenceAdapter()).getStore(); PersistenceAdapter persistenceAdapter = broker.getPersistenceAdapter();
LOG.info("Store page count: " + store.getPageFile().getPageCount()); if( persistenceAdapter instanceof KahaDBStore) {
LOG.info("Store free page count: " + store.getPageFile().getFreePageCount()); final KahaDBStore store = ((KahaDBPersistenceAdapter) persistenceAdapter).getStore();
LOG.info("Store page in-use: " + (store.getPageFile().getPageCount() - store.getPageFile().getFreePageCount())); LOG.info("Store page count: " + store.getPageFile().getPageCount());
LOG.info("Store free page count: " + store.getPageFile().getFreePageCount());
LOG.info("Store page in-use: " + (store.getPageFile().getPageCount() - store.getPageFile().getFreePageCount()));
assertTrue("no leak of pages, always use just 10", Wait.waitFor(new Wait.Condition() { assertTrue("no leak of pages, always use just 10", Wait.waitFor(new Wait.Condition() {
@Override @Override
public boolean isSatisified() throws Exception { public boolean isSatisified() throws Exception {
return 10 == store.getPageFile().getPageCount() - return 10 == store.getPageFile().getPageCount() -
store.getPageFile().getFreePageCount(); store.getPageFile().getFreePageCount();
} }
}, TimeUnit.SECONDS.toMillis(10))); }, TimeUnit.SECONDS.toMillis(10)));
}
} }
private void waitFor(final Listener listener, final int count) throws Exception { private void waitFor(final Listener listener, final int count) throws Exception {