Use transaction again as it works with Strings instead of QNames

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1124147 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 17 insertions, 18 deletions

diff --git a/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/registry/hazelcast/HazelcastDomainRegistry.java b/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/registry/hazelcast/HazelcastDomainRegistry.java
index 73c6409272..91bf6dbef3 100644
--- a/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/registry/hazelcast/HazelcastDomainRegistry.java
+++ b/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/registry/hazelcast/HazelcastDomainRegistry.java
@@ -514,27 +514,26 @@ public class HazelcastDomainRegistry extends BaseDomainRegistry implements Domai
     public void addRunningComposite(String curi, Composite composite) {
         String localMemberAddr = hazelcastInstance.getCluster().getLocalMember().getInetSocketAddress().toString();
         String compositeXML = writeComposite(composite);
-// TODO: doing this in a txn causes the values to get lost - looks like a bug in hazelcast        
         Transaction txn = hazelcastInstance.getTransaction();
         txn.begin();
         try {
-        Map<String, String> cs = runningComposites.get(curi);
-        if (cs == null) {
-            cs = new HashMap<String, String>();
-        }
-        cs.put(composite.getURI(), compositeXML);
-        runningComposites.put(curi, cs);
-        Map<String, List<String>> ocs = runningCompositeOwners.get(localMemberAddr);
-        if (ocs == null) {
-            ocs = new HashMap<String, List<String>>();
-        }
-        List<String> lcs = ocs.get(curi);
-        if (lcs == null) {
-            lcs = new ArrayList<String>();
-            ocs.put(curi, lcs);
-        }
-        lcs.add(composite.getURI());
-        runningCompositeOwners.put(localMemberAddr, ocs);
+            Map<String, String> cs = runningComposites.get(curi);
+            if (cs == null) {
+                cs = new HashMap<String, String>();
+            }
+            cs.put(composite.getURI(), compositeXML);
+            runningComposites.put(curi, cs);
+            Map<String, List<String>> ocs = runningCompositeOwners.get(localMemberAddr);
+            if (ocs == null) {
+                ocs = new HashMap<String, List<String>>();
+            }
+            List<String> lcs = ocs.get(curi);
+            if (lcs == null) {
+                lcs = new ArrayList<String>();
+                ocs.put(curi, lcs);
+            }
+            lcs.add(composite.getURI());
+            runningCompositeOwners.put(localMemberAddr, ocs);
             txn.commit();
         } catch (Throwable e) {
             txn.rollback();