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

1 files 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());
     }