svn commit: r1101784 - /tuscany/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java

[an...@apache.org]

Author: antelder
Date: Wed May 11 08:34:32 2011
New Revision: 1101784

URL: http://svn.apache.org/viewvc?rev=1101784&view=rev
Log:
Comment out the transaction processing for now as it looks like a hazelcast bug causes that to loses the values

Modified:
    tuscany/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java

Modified: tuscany/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java
URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java?rev=1101784&r1=1101783&r2=1101784&view=diff
==============================================================================
--- tuscany/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java (original)
+++ tuscany/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java Wed May 11 08:34:32 2011
@@ -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 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 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());
     }