From 5d4ba723c9874632da4cc958218416a81d6f27c1 Mon Sep 17 00:00:00 2001 From: antelder Date: Fri, 13 May 2011 15:02:17 +0000 Subject: Move the setting of the local endpoints to before the other stores to fix the case where the entryAdded is being driven first on anothe rthread which causes the isLocal test to give the wrong answer git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1102780 13f79535-47bb-0310-9956-ffa450edef68 --- .../tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java') 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 3ba62bbf85..1e93e77af8 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 @@ -271,6 +271,7 @@ public class HazelcastEndpointRegistry extends BaseEndpointRegistry implements E Transaction txn = hazelcastInstance.getTransaction(); txn.begin(); try { + localEndpoints.put(endpointURI, endpoint); endpointMap.put(endpointURI, endpoint); endpointWsdls.put(endpointURI, wsdl); endpointOwners.put(localMemberAddr, endpointURI); @@ -279,7 +280,6 @@ public class HazelcastEndpointRegistry extends BaseEndpointRegistry implements E txn.rollback(); throw new ServiceRuntimeException(e); } - localEndpoints.put(endpointURI, endpoint); logger.info("Add endpoint - " + endpoint); } -- cgit v1.2.3