diff options
author | rfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68> | 2009-12-11 21:50:34 +0000 |
---|---|---|
committer | rfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68> | 2009-12-11 21:50:34 +0000 |
commit | d4a4398c1c9dfd6bff2b329cd62ee390d8dbe660 (patch) | |
tree | 709bad8e87615840c97e976b9f8b9751e7a3aa82 /sca-java-2.x/trunk/modules | |
parent | ac9b7bcf6f2f8f571556332edbeb4dafdf5e547a (diff) |
Fix svn:ignore and compliation error
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@889830 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'sca-java-2.x/trunk/modules')
-rw-r--r-- | sca-java-2.x/trunk/modules/endpoint-dht/src/main/java/org/apache/tuscany/sca/endpoint/dht/OverlayEndpointRegistry.java | 25 |
1 files changed, 14 insertions, 11 deletions
diff --git a/sca-java-2.x/trunk/modules/endpoint-dht/src/main/java/org/apache/tuscany/sca/endpoint/dht/OverlayEndpointRegistry.java b/sca-java-2.x/trunk/modules/endpoint-dht/src/main/java/org/apache/tuscany/sca/endpoint/dht/OverlayEndpointRegistry.java index 04b260de0f..015cf64c39 100644 --- a/sca-java-2.x/trunk/modules/endpoint-dht/src/main/java/org/apache/tuscany/sca/endpoint/dht/OverlayEndpointRegistry.java +++ b/sca-java-2.x/trunk/modules/endpoint-dht/src/main/java/org/apache/tuscany/sca/endpoint/dht/OverlayEndpointRegistry.java @@ -19,31 +19,32 @@ package org.apache.tuscany.sca.endpoint.dht; +import java.io.IOException; import java.net.InetAddress; import java.net.NetworkInterface; import java.util.ArrayList; import java.util.Enumeration; import java.util.List; import java.util.Map; -import java.util.UUID; -import java.util.concurrent.CopyOnWriteArrayList; -import java.util.concurrent.ConcurrentHashMap; import java.util.Set; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.CopyOnWriteArrayList; import java.util.logging.Level; import java.util.logging.Logger; -import ow.id.ID; -import ow.routing.RoutingException; -import ow.dht.DHT; -import ow.dht.DHTConfiguration; -import ow.dht.DHTFactory; -import ow.dht.ValueInfo; -import java.io.IOException; + import org.apache.tuscany.sca.assembly.Endpoint; import org.apache.tuscany.sca.assembly.EndpointReference; import org.apache.tuscany.sca.core.ExtensionPointRegistry; import org.apache.tuscany.sca.core.LifeCycleListener; import org.apache.tuscany.sca.runtime.EndpointListener; import org.apache.tuscany.sca.runtime.EndpointRegistry; +import org.apache.tuscany.sca.runtime.RuntimeEndpoint; + +import ow.dht.DHT; +import ow.dht.DHTConfiguration; +import ow.dht.DHTFactory; +import ow.dht.ValueInfo; +import ow.id.ID; /** * A EndpointRegistry based on Overlay Weaver DHT @@ -200,7 +201,9 @@ public class OverlayEndpointRegistry implements EndpointRegistry, LifeCycleListe endpoint.setRemote(true); } - endpoint.setExtensionPointRegistry(registry); + if(endpoint instanceof RuntimeEndpoint) { + ((RuntimeEndpoint) endpoint).bind(registry, this); + } foundEndpoints.add(endpoint); logger.info("Found endpoint with matching service - " + endpoint); |