diff options
author | antelder <antelder@13f79535-47bb-0310-9956-ffa450edef68> | 2011-05-13 15:02:17 +0000 |
---|---|---|
committer | antelder <antelder@13f79535-47bb-0310-9956-ffa450edef68> | 2011-05-13 15:02:17 +0000 |
commit | 5d4ba723c9874632da4cc958218416a81d6f27c1 (patch) | |
tree | f09c0253da0085791e3e721ce5416a5bea32b910 /sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca | |
parent | 33cebe17465a63c1620f41443dc9417cc2cabb09 (diff) |
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
Diffstat (limited to 'sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca')
-rw-r--r-- | sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java | 2 |
1 files changed, 1 insertions, 1 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 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); } |