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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
