diff options
author | antelder <antelder@13f79535-47bb-0310-9956-ffa450edef68> | 2010-03-20 12:30:23 +0000 |
---|---|---|
committer | antelder <antelder@13f79535-47bb-0310-9956-ffa450edef68> | 2010-03-20 12:30:23 +0000 |
commit | c1b86fd22aa7796f287e086c36e88490d1c33abe (patch) | |
tree | 418ba8e9d05b51084053774b484a11028e613757 /sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main | |
parent | 08286cba493d30f4bed3a42a320ccb103b9904d6 (diff) |
Fix Hazelcast client to correckt initilize Hazelcast registry endpointOwners and getHazelcastInstance
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@925589 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to '')
-rw-r--r-- | sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java | 4 |
1 files changed, 2 insertions, 2 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 35cab29479..a170376e07 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 @@ -66,7 +66,7 @@ public class HazelcastEndpointRegistry extends BaseEndpointRegistry implements E private HazelcastInstance hazelcastInstance;
protected Map<Object, Object> endpointMap;
private Map<String, Endpoint> localEndpoints = new HashMap<String, Endpoint>();
- private MultiMap<String, String> endpointOwners;
+ protected MultiMap<String, String> endpointOwners;
private AssemblyFactory assemblyFactory;
public HazelcastEndpointRegistry(ExtensionPointRegistry registry,
@@ -303,7 +303,7 @@ public class HazelcastEndpointRegistry extends BaseEndpointRegistry implements E Endpoint ep = assemblyFactory.createEndpoint();
ep.setURI(service);
if (ep.matches(serviceURI)) {
- for (Member m : hazelcastInstance.getCluster().getMembers()) {
+ for (Member m : getHazelcastInstance().getCluster().getMembers()) {
if (memberAddr.equals(m.getInetSocketAddress().toString())) {
return m;
}
|