From 8703d6e9b35f6139ba89525bd3bb15bd9039f3ac Mon Sep 17 00:00:00 2001
From: antelder <antelder@13f79535-47bb-0310-9956-ffa450edef68>
Date: Wed, 18 May 2011 09:42:01 +0000
Subject: 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
---
 .../hazelcast/HazelcastDomainRegistry.java         | 35 +++++++++++-----------
 1 file changed, 17 insertions(+), 18 deletions(-)

(limited to 'sca-java-2.x/trunk/modules/domain-hazelcast/src/main')

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();
-- 
cgit v1.2.3