From 030c44a5540b35f4c24af3e60cced2c008e15215 Mon Sep 17 00:00:00 2001
From: gtully <gary.tully@gmail.com>
Date: Mon, 16 Jan 2017 11:11:45 +0000
Subject: [PATCH] [no jira] ensure clean db for test AMQ6463Test - intermittent
 ci failure

---
 .../src/test/java/org/apache/activemq/bugs/AMQ6463Test.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6463Test.java b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6463Test.java
index d63e57b7e4..d3996bf1e7 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6463Test.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6463Test.java
@@ -73,12 +73,12 @@ public class AMQ6463Test extends JmsTestSupport {
         producer.close();
 
         // lets not consume till producer is blocked
-        Wait.waitFor(new Wait.Condition() {
+        assertTrue("got blocked event", Wait.waitFor(new Wait.Condition() {
             @Override
             public boolean isSatisified() throws Exception {
                 return gotUsageBlocked.get();
             }
-        });
+        }));
 
         MessageConsumer consumer = session.createConsumer(queueA);
         TextMessage msg;
@@ -97,6 +97,7 @@ public class AMQ6463Test extends JmsTestSupport {
         service.setPersistent(true);
         service.setUseJmx(false);
         service.setSchedulerSupport(true);
+        service.setDeleteAllMessagesOnStartup(true);
 
         // Setup a destination policy where it takes only 1 message at a time.
         PolicyMap policyMap = new PolicyMap();