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 <[email protected]> Authored: Thu Mar 22 11:56:36 2018 +0000 Committer: Keith Wall <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
