Comment out transaction code in Hazelcast registry while the Hazelcast issue is investigated

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

1 files changed, 11 insertions, 9 deletions

diff --git a/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java b/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java
index c97a81080d..40d17da57d 100644
--- a/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java
+++ b/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java
@@ -232,16 +232,18 @@ public class HazelcastEndpointRegistry extends BaseEndpointRegistry implements E
         synchronized (shutdownMutex) {

             String localMemberAddr = hazelcastInstance.getCluster().getLocalMember().getInetSocketAddress().toString();

             String endpointURI = endpoint.getURI();

-            Transaction txn = hazelcastInstance.getTransaction();

-            txn.begin();

-            try {

-                endpointMap.remove(endpointURI);

+            

+// TODO: seems to be a txn bug in Hazelcast, see http://code.google.com/p/hazelcast/issues/detail?id=258 

+//            Transaction txn = hazelcastInstance.getTransaction();

+//            txn.begin();

+//            try {

                 endpointOwners.remove(localMemberAddr, endpointURI);

-                txn.commit();

-            } catch (Throwable e) {

-                txn.rollback();

-                throw new ServiceRuntimeException(e);

-            }

+                endpointMap.remove(endpointURI);

+//                txn.commit();

+//            } catch (Throwable e) {

+//                txn.rollback();

+//                throw new ServiceRuntimeException(e);

+//            }

             localEndpoints.remove(endpointURI);

             logger.info("Removed endpoint - " + endpoint);

         }