diff options
Diffstat (limited to 'sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main')
-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;
}
|