You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tuscany.apache.org by rf...@apache.org on 2009/12/11 22:50:38 UTC

svn commit: r889830 - in /tuscany/sca-java-2.x/trunk/modules/endpoint-dht: ./ src/main/java/org/apache/tuscany/sca/endpoint/dht/OverlayEndpointRegistry.java

Author: rfeng
Date: Fri Dec 11 21:50:34 2009
New Revision: 889830

URL: http://svn.apache.org/viewvc?rev=889830&view=rev
Log:
Fix svn:ignore and compliation error

Modified:
    tuscany/sca-java-2.x/trunk/modules/endpoint-dht/   (props changed)
    tuscany/sca-java-2.x/trunk/modules/endpoint-dht/src/main/java/org/apache/tuscany/sca/endpoint/dht/OverlayEndpointRegistry.java

Propchange: tuscany/sca-java-2.x/trunk/modules/endpoint-dht/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Fri Dec 11 21:50:34 2009
@@ -0,0 +1,20 @@
+target
+work
+dojo
+*.iws
+*.ipr
+*.iml
+derby.log
+maven.log
+maven-eclipse.xml
+build.xml
+build-dependency.xml
+velocity.log*
+junit*.properties
+surefire*.properties
+.project
+.classpath
+.settings
+.deployables
+.wtpmodules
+.externalToolBuilders

Modified: tuscany/sca-java-2.x/trunk/modules/endpoint-dht/src/main/java/org/apache/tuscany/sca/endpoint/dht/OverlayEndpointRegistry.java
URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/endpoint-dht/src/main/java/org/apache/tuscany/sca/endpoint/dht/OverlayEndpointRegistry.java?rev=889830&r1=889829&r2=889830&view=diff
==============================================================================
--- tuscany/sca-java-2.x/trunk/modules/endpoint-dht/src/main/java/org/apache/tuscany/sca/endpoint/dht/OverlayEndpointRegistry.java (original)
+++ tuscany/sca-java-2.x/trunk/modules/endpoint-dht/src/main/java/org/apache/tuscany/sca/endpoint/dht/OverlayEndpointRegistry.java Fri Dec 11 21:50:34 2009
@@ -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 @@
 				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);