You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kw...@apache.org on 2018/03/22 11:59:35 UTC
qpid-broker-j git commit: QPID-8123: [BDB System Tests] Fix
MultiNodeTest#testInFlightTransactionsWhilstMajorityIsLost on the AMQP 1.0
path so that JMS clientId is not shared amongst the producers.
Repository: qpid-broker-j
Updated Branches:
refs/heads/master 069ad6733 -> 4fbab0e59
QPID-8123: [BDB System Tests] Fix MultiNodeTest#testInFlightTransactionsWhilstMajorityIsLost on the AMQP 1.0 path so that JMS clientId is not shared amongst the producers.
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/4fbab0e5
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/4fbab0e5
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/4fbab0e5
Branch: refs/heads/master
Commit: 4fbab0e59c69e143039bb76b2a9b130dd5d35781
Parents: 069ad67
Author: Keith Wall <kw...@apache.org>
Authored: Thu Mar 22 11:56:36 2018 +0000
Committer: Keith Wall <kw...@apache.org>
Committed: Thu Mar 22 11:59:28 2018 +0000
----------------------------------------------------------------------
.../qpid/server/store/berkeleydb/replication/MultiNodeTest.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/4fbab0e5/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/MultiNodeTest.java
----------------------------------------------------------------------
diff --git a/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/MultiNodeTest.java b/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/MultiNodeTest.java
index c964655..b80f002 100644
--- a/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/MultiNodeTest.java
+++ b/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/MultiNodeTest.java
@@ -488,8 +488,8 @@ public class MultiNodeTest extends QpidBrokerTestCase
ExecutorService executorService = Executors.newFixedThreadPool(connectionNumber + NUMBER_OF_NODES - 1);
try
{
- final ConnectionBuilder builder = _groupCreator.getConnectionBuilderForAllClusterNodes(100, 100);
- final Connection consumerConnection = builder.build();
+ final ConnectionBuilder consumerBuilder = _groupCreator.getConnectionBuilderForAllClusterNodes(100, 100);
+ final Connection consumerConnection = consumerBuilder.build();
Session s = consumerConnection.createSession(true, Session.SESSION_TRANSACTED);
getJmsProvider().createQueue(s, getTestQueueName());
s.close();
@@ -513,6 +513,7 @@ public class MultiNodeTest extends QpidBrokerTestCase
final Session[] sessions = new Session[connectionNumber];
for (int i = 0; i < sessions.length; i++)
{
+ final ConnectionBuilder builder = _groupCreator.getConnectionBuilderForAllClusterNodes(100, 100);
connections[i] = builder.build();
sessions[i] = connections[i].createSession(true, Session.SESSION_TRANSACTED);
LOGGER.info("Session {} is created", i);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org