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

Fix test case, an additional log file is retained now that we are more careful about tracking acks that are needed for recovery from the journal. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1487636 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2013-05-29 20:43:11 +00:00
parent 97e1edc20c
commit 646d0234d7
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
activemq-unit-tests/src/test/java/org/apache/activemq/usecases/DurableSubscriptionOfflineTest.java
View File

@ -1505,8 +1505,15 @@ public class DurableSubscriptionOfflineTest extends org.apache.activemq.TestSupp
destroyBroker();
createBroker(false);
KahaDBPersistenceAdapter pa = (KahaDBPersistenceAdapter) broker.getPersistenceAdapter();
assertEquals("only two journal file(s) left after restart", 2, pa.getStore().getJournal().getFileMap().size());
final KahaDBPersistenceAdapter pa = (KahaDBPersistenceAdapter) broker.getPersistenceAdapter();
assertTrue("Should have three journal files left but was: " +
pa.getStore().getJournal().getFileMap().size(), Wait.waitFor(new Wait.Condition() {
@Override
public boolean isSatisified() throws Exception {
return pa.getStore().getJournal().getFileMap().size() == 3;
}
}));
}
// https://issues.apache.org/jira/browse/AMQ-3768