You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2017/11/28 10:03:28 UTC
qpid-broker-j git commit: QPID-6933: [System Tests] Fix failing test
Repository: qpid-broker-j
Updated Branches:
refs/heads/master 59218fdc3 -> c401deb7e
QPID-6933: [System Tests] Fix failing test
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/c401deb7
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/c401deb7
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/c401deb7
Branch: refs/heads/master
Commit: c401deb7e2e4c321518b0c925e653cb157e28cae
Parents: 59218fd
Author: Alex Rudyy <or...@apache.org>
Authored: Tue Nov 28 10:01:50 2017 +0000
Committer: Alex Rudyy <or...@apache.org>
Committed: Tue Nov 28 10:01:50 2017 +0000
----------------------------------------------------------------------
.../qpid/systests/jms_1_1/topic/DurableSubscribtionTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/c401deb7/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/topic/DurableSubscribtionTest.java
----------------------------------------------------------------------
diff --git a/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/topic/DurableSubscribtionTest.java b/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/topic/DurableSubscribtionTest.java
index 6fb54cc..c71b118 100644
--- a/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/topic/DurableSubscribtionTest.java
+++ b/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/topic/DurableSubscribtionTest.java
@@ -279,10 +279,10 @@ public class DurableSubscribtionTest extends Jms1TestBase
Topic topic = createTopic(getTestName());
String clientId = "testClientId";
- Connection connection = getConnectionBuilder().setClientId(clientId).build();
+ Connection publishingConnection = getConnectionBuilder().setClientId("publishingConnection").build();
try
{
- Session session = connection.createSession(true, Session.SESSION_TRANSACTED);
+ Session session = publishingConnection.createSession(true, Session.SESSION_TRANSACTED);
MessageProducer sessionProducer = session.createProducer(topic);
Connection noLocalConnection = getConnectionBuilder().setClientId(clientId).build();
@@ -294,7 +294,7 @@ public class DurableSubscribtionTest extends Jms1TestBase
TopicSubscriber noLocalSubscriber =
noLocalSession.createDurableSubscriber(topic, noLocalSubscriptionName, null, true);
noLocalConnection.start();
- connection.start();
+ publishingConnection.start();
noLocalSessionProducer.send(noLocalSession.createTextMessage("Message1"));
noLocalSession.commit();
@@ -345,7 +345,7 @@ public class DurableSubscribtionTest extends Jms1TestBase
}
finally
{
- connection.close();
+ publishingConnection.close();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org