From e4cee24b41a6ddbb8981c638fb444319e9401f11 Mon Sep 17 00:00:00 2001
From: antelder <antelder@13f79535-47bb-0310-9956-ffa450edef68>
Date: Wed, 11 May 2011 08:34:32 +0000
Subject: Comment out the transaction processing for now as it looks like a
 hazelcast bug causes that to loses the values

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1101784 13f79535-47bb-0310-9956-ffa450edef68
---
 .../hazelcast/HazelcastEndpointRegistry.java       | 25 +++++++++++++++-------
 1 file changed, 17 insertions(+), 8 deletions(-)

diff --git a/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java b/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java
index a0144b0a63..c81b2d893a 100644
--- a/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java
+++ b/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java
@@ -29,6 +29,7 @@ import java.util.Collection;
 import java.util.List;
 import java.util.Map;
 import java.util.Properties;
+import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.logging.Level;
 import java.util.logging.Logger;
@@ -492,16 +493,17 @@ public class HazelcastEndpointRegistry extends BaseEndpointRegistry implements E
     public void addRunningComposite(Composite composite) {
         String localMemberAddr = hazelcastInstance.getCluster().getLocalMember().getInetSocketAddress().toString();
         String compositeXML = writeComposite(composite);
-        Transaction txn = hazelcastInstance.getTransaction();
-        txn.begin();
-        try {
+// 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 {
             runningComposites.put(composite.getName(), compositeXML);
             runningCompositeOwners.put(localMemberAddr, composite.getName());
-            txn.commit();
-        } catch (Throwable e) {
-            txn.rollback();
-            throw new ServiceRuntimeException(e);
-        }
+//            txn.commit();
+//        } catch (Throwable e) {
+//            txn.rollback();
+//            throw new ServiceRuntimeException(e);
+//        }
     }
 
     public void removeRunningComposite(QName name) {
@@ -524,6 +526,13 @@ public class HazelcastEndpointRegistry extends BaseEndpointRegistry implements E
     }
 
     public List<QName> getRunningCompositeNames() {
+//        List<QName> names = new ArrayList<QName>();
+//        for (String s : runningCompositeOwners.keySet()) {
+//            for (QName name : runningCompositeOwners.get(s)) {
+//                names.add(name);
+//            }
+//        }
+//        return names;
         return new ArrayList<QName>(runningCompositeOwners.values());
     }
 
-- 
cgit v1.2.3