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;
                         }