summaryrefslogtreecommitdiffstats
path: root/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java
diff options
context:
space:
mode:
authorrfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68>2010-02-26 18:23:06 +0000
committerrfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68>2010-02-26 18:23:06 +0000
commit3566e4b599bcc88382ad81433229b6f2cccdb899 (patch)
tree067b84f33391c785780b8ab30066651d8bec9e7b /sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java
parentb4f0e720cda98d4bdaa351f4509d6486537a60f6 (diff)
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
Diffstat (limited to 'sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java')
-rw-r--r--sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java6
1 files changed, 1 insertions, 5 deletions
diff --git a/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java b/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
index e581fa22d1..a3d33f8235 100644
--- a/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
+++ b/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
@@ -49,9 +49,9 @@ import org.apache.tuscany.sca.core.LifeCycleListener;
import org.apache.tuscany.sca.endpoint.tribes.AbstractReplicatedMap.MapEntry;
import org.apache.tuscany.sca.endpoint.tribes.MapStore.MapListener;
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;
/**
* A replicated EndpointRegistry based on Apache Tomcat Tribes
@@ -298,9 +298,6 @@ public class ReplicatedEndpointRegistry extends BaseEndpointRegistry implements
logger.fine("Matching against - " + endpoint);
if (matches(uri, endpoint.getURI())) {
MapEntry entry = map.getInternal(endpoint.getURI());
- if (!isLocal(entry)) {
- endpoint.setRemote(true);
- }
// if (!entry.isPrimary()) {
((RuntimeEndpoint)endpoint).bind(registry, this);
// }
@@ -362,7 +359,6 @@ public class ReplicatedEndpointRegistry extends BaseEndpointRegistry implements
Endpoint newEp = (Endpoint)entry.getValue();
if (!isLocal(entry)) {
logger.info(id + " Remote endpoint added: " + entry.getValue());
- newEp.setRemote(true);
}
endpointAdded(newEp);
}