From 3566e4b599bcc88382ad81433229b6f2cccdb899 Mon Sep 17 00:00:00 2001 From: rfeng Date: Fri, 26 Feb 2010 18:23:06 +0000 Subject: Clean up the remote flag for endpoint and change the endpoint reference status to an enum git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@916778 13f79535-47bb-0310-9956-ffa450edef68 --- .../tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) (limited to 'sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast') 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 88a45bbf4c..c91189fb44 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 @@ -30,12 +30,11 @@ import org.apache.tuscany.sca.assembly.Endpoint; import org.apache.tuscany.sca.core.ExtensionPointRegistry; import org.apache.tuscany.sca.core.LifeCycleListener; import org.apache.tuscany.sca.runtime.BaseEndpointRegistry; +import org.apache.tuscany.sca.runtime.DomainRegistryURI; import org.apache.tuscany.sca.runtime.EndpointRegistry; import org.apache.tuscany.sca.runtime.RuntimeEndpoint; -import org.apache.tuscany.sca.runtime.DomainRegistryURI; import com.hazelcast.config.Config; -import com.hazelcast.config.MapConfig; import com.hazelcast.config.NearCacheConfig; import com.hazelcast.config.TcpIpConfig; import com.hazelcast.config.XmlConfigBuilder; @@ -149,7 +148,6 @@ public class HazelcastEndpointRegistry extends BaseEndpointRegistry implements E logger.fine("Matching against - " + endpoint); if (matches(uri, endpoint.getURI())) { if (!isLocal(endpoint)) { - endpoint.setRemote(true); ((RuntimeEndpoint)endpoint).bind(registry, this); } else { // get the local version of the endpoint @@ -206,7 +204,6 @@ public class HazelcastEndpointRegistry extends BaseEndpointRegistry implements E Endpoint newEp = (Endpoint)value; if (!isLocal(newEp)) { logger.info(" Remote endpoint added: " + newEp); - newEp.setRemote(true); } endpointAdded(newEp); } -- cgit v1.2.3