diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
index 0cdb895d1b..38011681ad 100644
--- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
+++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
@@ -886,7 +886,7 @@ public class JMSClientTest extends JMSClientTestSupport {
     }
 
     @Test(timeout=30*1000)
-    public void simpleDurableTopicTest() throws Exception {
+    public void testDurableTopicStateAfterSubscriberClosed() throws Exception {
         String durableClientId = getDestinationName() + "-ClientId";
         String durableSubscriberName = getDestinationName() + "-SubscriptionName";
 
@@ -896,7 +896,7 @@ public class JMSClientTest extends JMSClientTestSupport {
         LOG.debug(">>>> At Start, durable Subscribers {} inactiveDurableSubscribers {}", durableSubscribersAtStart, inactiveSubscribersAtStart);
 
         TopicConnection subscriberConnection =
-            JMSClientContext.INSTANCE.createTopicConnection(amqpURI, "admin", "password");
+            JMSClientContext.INSTANCE.createTopicConnection(getBrokerURI(), "admin", "password");
         subscriberConnection.setClientID(durableClientId);
         TopicSession subscriberSession = subscriberConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
         Topic topic = subscriberSession.createTopic(getDestinationName());