qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From oru...@apache.org
Subject [qpid-broker-j] branch master updated: QPID-8407: [Broker-J] Fix test
Date Wed, 29 Jan 2020 10:32:58 GMT
This is an automated email from the ASF dual-hosted git repository.

orudyy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git


The following commit(s) were added to refs/heads/master by this push:
     new f39588d  QPID-8407: [Broker-J] Fix test
f39588d is described below

commit f39588d3df938412ba736f560beb71ebd22cb2c6
Author: Alex Rudyy <orudyy@apache.org>
AuthorDate: Wed Jan 29 10:31:19 2020 +0000

    QPID-8407: [Broker-J] Fix test
---
 .../server/store/berkeleydb/replication/MultiNodeTest.java     | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

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 92e253a..bf1cfed 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
@@ -59,6 +59,7 @@ import javax.jms.Session;
 import javax.jms.TextMessage;
 import javax.jms.TransactionRolledBackException;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.sleepycat.je.Durability;
 import com.sleepycat.je.EnvironmentConfig;
 import com.sleepycat.je.rep.ReplicatedEnvironment;
@@ -914,15 +915,16 @@ public class MultiNodeTest extends GroupJmsTestBase
         }
     }
 
-    private void configureAsynchronousRecoveryOnAllNodes()
+    private void configureAsynchronousRecoveryOnAllNodes() throws Exception
     {
         final GroupBrokerAdmin brokerAdmin = getBrokerAdmin();
+        final String contextValue = new ObjectMapper().writeValueAsString(Collections.singletonMap(
+                "use_async_message_store_recovery",
+                "true"));
         for (int port : brokerAdmin.getGroupAmqpPorts())
         {
             brokerAdmin.setNodeAttributes(port, Collections.singletonMap(BDBHAVirtualHostNode.CONTEXT,
-                                                                         Collections.singletonMap(
-                                                                                 "use_async_message_store_recovery",
-                                                                                 "true")));
+                                                                         contextValue));
             brokerAdmin.stopNode(port);
             brokerAdmin.startNode(port);
             brokerAdmin.awaitNodeRole(port, BDBHARemoteReplicationNode.ROLE, "REPLICA", "MASTER");


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message