This is an automated email from the ASF dual-hosted git repository. orudyy pushed a commit to branch 7.1.x in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
commit 17640005301ee061bd962a24c35a107f89b49704 Author: Alex Rudyy <[email protected]> AuthorDate: Wed Jan 29 10:31:19 2020 +0000 QPID-8407: [Broker-J] Fix test (cherry picked from commit f39588d3df938412ba736f560beb71ebd22cb2c6) --- .../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: [email protected] For additional commands, e-mail: [email protected]
