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);