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

This closes #2593

This commit is contained in:
Michael Andre Pearce 2019-03-27 17:00:28 +00:00
parent 6bc2d2e741 38493e3d17
commit 022223d383
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/BackupSyncJournalTest.java
View File

@ -338,6 +338,16 @@ public class BackupSyncJournalTest extends FailoverTestBase {
assertNoMoreMessages();
}
@Test
public void testReceiveAllMessagesWithPurgeOnNoConsumers() throws Exception {
final boolean purgeOnNoConsumers = true;
createProducerSendSomeMessages();
liveServer.getServer().locateQueue(ADDRESS).setPurgeOnNoConsumers(purgeOnNoConsumers);
receiveMsgsInRange(0, n_msgs);
startBackupCrashLive();
assertNoMoreMessages();
}
private void startBackupCrashLive() throws Exception {
assertFalse("backup is started?", backupServer.isStarted());
liveServer.removeInterceptor(syncDelay);