QPID-5715: Add new attributes for transaction sync policies into BDB HA virtual host,

           remove 'coalescingSync' attribute from BDB HA virtual host node and always use coalescingSync with replicated environment,
           change attribute 'durability' of  BDB HA virtual host node into derived attribute,
           delegate bdb je transaction creation to EnvironmentFacade,
           with ReplicatedEnvironmentFacade crate transactions with durability having virtual host transaction sync policies
           and ack mode 'SIMPLE_MAJORITY'.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1597801 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 15 insertions, 0 deletions

diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/systest/rest/QpidRestTestCase.java b/qpid/java/systests/src/main/java/org/apache/qpid/systest/rest/QpidRestTestCase.java
index 9322f79984..3eba4fad21 100644
--- a/qpid/java/systests/src/main/java/org/apache/qpid/systest/rest/QpidRestTestCase.java
+++ b/qpid/java/systests/src/main/java/org/apache/qpid/systest/rest/QpidRestTestCase.java
@@ -22,6 +22,7 @@ package org.apache.qpid.systest.rest;
 
 import java.io.IOException;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 
 import org.apache.qpid.server.management.plugin.HttpManagement;
@@ -102,4 +103,18 @@ public class QpidRestTestCase extends QpidBrokerTestCase
     {
         return _restTestHelper;
     }
+
+    public Map<String, Object> waitForAttributeChanged(String url, String attributeName, Object newValue) throws Exception
+    {
+        List<Map<String, Object>> nodeAttributes = getRestTestHelper().getJsonAsList(url);
+        long limit = System.currentTimeMillis() + 5000;
+        while(System.currentTimeMillis() < limit && (nodeAttributes.size() == 0 || !newValue.equals(nodeAttributes.get(0).get(attributeName))))
+        {
+            Thread.sleep(100l);
+            nodeAttributes = getRestTestHelper().getJsonAsList(url);
+        }
+        Map<String, Object> nodeData = nodeAttributes.get(0);
+        assertEquals("Unexpected attribute " + attributeName, newValue, nodeData.get(attributeName));
+        return nodeData;
+    }
 }