AMQ-5035 - fix intermittent failure due to async close
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5035Test.java b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5035Test.java
index f552b15..b729990 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5035Test.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5035Test.java
@@ -17,8 +17,10 @@
package org.apache.activemq.bugs;
import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
import javax.jms.Connection;
+import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.Topic;
@@ -72,7 +74,11 @@
consumer.close();
BrokerViewMBean brokerView = getBrokerView(DURABLE_SUB_NAME);
- brokerView.destroyDurableSubscriber(CLIENT_ID, DURABLE_SUB_NAME);
+ try {
+ brokerView.destroyDurableSubscriber(CLIENT_ID, DURABLE_SUB_NAME);
+ } catch (JMSException okAsCloseIsAsync) {
+ assertTrue("inactive reason", okAsCloseIsAsync.getMessage().contains("in use"));
+ }
}
private BrokerViewMBean getBrokerView(String testDurable) throws MalformedObjectNameException {
