summaryrefslogtreecommitdiffstats
path: root/sca-java-2.x/trunk/modules/endpoint-dht/src/main
diff options
context:
space:
mode:
authorrfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68>2009-12-11 21:50:34 +0000
committerrfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68>2009-12-11 21:50:34 +0000
commitd4a4398c1c9dfd6bff2b329cd62ee390d8dbe660 (patch)
tree709bad8e87615840c97e976b9f8b9751e7a3aa82 /sca-java-2.x/trunk/modules/endpoint-dht/src/main
parentac9b7bcf6f2f8f571556332edbeb4dafdf5e547a (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/endpoint-dht/src/main')
-rw-r--r--sca-java-2.x/trunk/modules/endpoint-dht/src/main/java/org/apache/tuscany/sca/endpoint/dht/OverlayEndpointRegistry.java25
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);