Author: borges
Date: 2011-08-01 09:51:31 -0400 (Mon, 01 Aug 2011)
New Revision: 11086
Modified:
branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/BackupJournalSyncTest.java
Log:
HORNETQ-720 Adjust unit-test
Modified:
branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/BackupJournalSyncTest.java
===================================================================
---
branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/BackupJournalSyncTest.java 2011-08-01
13:50:45 UTC (rev 11085)
+++
branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/BackupJournalSyncTest.java 2011-08-01
13:51:31 UTC (rev 11086)
@@ -56,14 +56,13 @@
sendMessages(session, producer, N_MSGS);
}
backupServer.start();
- waitForBackup(sessionFactory, 5);
+ waitForBackup(sessionFactory, 10);
// XXX HORNETQ-720 must wait for backup to sync!
JournalImpl backupMsgJournal = getMessageJournalFromServer(backupServer);
- Set<Long> bckpIds = getFileIds(backupMsgJournal);
- assertFalse(bckpIds.isEmpty());
+ Set<Long> backupIds = getFileIds(backupMsgJournal);
Set<Long> liveIds = getFileIds(messageJournal);
- assertEquals("sets must match! " + liveIds, bckpIds, liveIds);
+ assertEquals("sets must match! " + liveIds, liveIds, backupIds);
}
/**
Show replies by date