Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-03-03 06:39:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix test breakage after: https://issues.apache.org/jira/browse/AMQ-3833

Browse Source 
The producerAudit is only written out on change so in this test it holds onto another log file meaning there are two left instead of one.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1434067 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2013-01-16 18:04:31 +00:00
parent 59d13ad913
commit f551570d4c
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-core/src/test/java/org/apache/activemq/usecases/DurableSubProcessMultiRestartTest.java
View File

@ -114,12 +114,12 @@ public class DurableSubProcessMultiRestartTest {
assertTrue("no exceptions: " + exceptions, exceptions.isEmpty()); assertTrue("no exceptions: " + exceptions, exceptions.isEmpty());
final KahaDBPersistenceAdapter pa = (KahaDBPersistenceAdapter) broker.getPersistenceAdapter(); final KahaDBPersistenceAdapter pa = (KahaDBPersistenceAdapter) broker.getPersistenceAdapter();
assertTrue("only one journal file should be left: " + pa.getStore().getJournal().getFileMap().size(), assertTrue("only two journal files should be left: " + pa.getStore().getJournal().getFileMap().size(),
Wait.waitFor(new Wait.Condition() { Wait.waitFor(new Wait.Condition() {
@Override @Override
public boolean isSatisified() throws Exception { public boolean isSatisified() throws Exception {
return pa.getStore().getJournal().getFileMap().size() == 1; return pa.getStore().getJournal().getFileMap().size() == 2;
} }
}, TimeUnit.MINUTES.toMillis(3)) }, TimeUnit.MINUTES.toMillis(3))
); );