From 7d4913b2d064222d411f55cf8aa60524253466dd Mon Sep 17 00:00:00 2001
From: antelder <antelder@13f79535-47bb-0310-9956-ffa450edef68>
Date: Mon, 19 Apr 2010 15:44:44 +0000
Subject: 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
---
 .../hazelcast/HazelcastEndpointRegistry.java         | 20 +++++++++++---------
 1 file changed, 11 insertions(+), 9 deletions(-)

(limited to 'sca-java-2.x/trunk/modules')

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