[activemq-artemis] branch master updated: ARTEMIS-2264 Added test that receive all messages instead of remove

[michaelpearce]

This is an automated email from the ASF dual-hosted git repository.

michaelpearce pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new 38493e3  ARTEMIS-2264 Added test that receive all messages instead of 
remove
     new 022223d  This closes #2593
38493e3 is described below

commit 38493e3d17d4c53f0c7b7863e0ca230025f844da
Author: Francesco Nigro <nigro....@gmail.com>
AuthorDate: Wed Mar 27 09:46:25 2019 +0100

    ARTEMIS-2264 Added test that receive all messages instead of remove
---
 .../integration/cluster/failover/BackupSyncJournalTest.java    | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/BackupSyncJournalTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/BackupSyncJournalTest.java
index f1d23be..aae8427 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/BackupSyncJournalTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/BackupSyncJournalTest.java
@@ -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);