summaryrefslogtreecommitdiffstats
path: root/sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java
diff options
context:
space:
mode:
authorantelder <antelder@13f79535-47bb-0310-9956-ffa450edef68>2011-05-13 15:02:17 +0000
committerantelder <antelder@13f79535-47bb-0310-9956-ffa450edef68>2011-05-13 15:02:17 +0000
commit5d4ba723c9874632da4cc958218416a81d6f27c1 (patch)
treef09c0253da0085791e3e721ce5416a5bea32b910 /sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java
parent33cebe17465a63c1620f41443dc9417cc2cabb09 (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')
-rw-r--r--sca-java-2.x/trunk/modules/domain-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java2
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);
}