You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2015/02/26 22:20:42 UTC
[7/7] activemq git commit:
https://issues.apache.org/jira/browse/AMQ-5617
https://issues.apache.org/jira/browse/AMQ-5617
Fix test failure and give it a more meaningful name.
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/eaf773da
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/eaf773da
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/eaf773da
Branch: refs/heads/master
Commit: eaf773da578a2827f9fe87be05676148ac31e90e
Parents: 276ef15
Author: Timothy Bish <ta...@gmail.com>
Authored: Thu Feb 26 16:06:33 2015 -0500
Committer: Timothy Bish <ta...@gmail.com>
Committed: Thu Feb 26 16:06:33 2015 -0500
----------------------------------------------------------------------
.../java/org/apache/activemq/transport/amqp/JMSClientTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/eaf773da/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
----------------------------------------------------------------------
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 0cdb895..3801168 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());