summaryrefslogtreecommitdiffstats
path: root/branches/sca-java-2.0-M4/modules/endpoint-tribes/src/main/java
diff options
context:
space:
mode:
authorrfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68>2009-11-03 00:14:53 +0000
committerrfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68>2009-11-03 00:14:53 +0000
commit56589672690a32a51b4fb1273133ffbe17f38739 (patch)
tree8e8d71840fa9c924874b766ae800454707e6fa42 /branches/sca-java-2.0-M4/modules/endpoint-tribes/src/main/java
parent960ec639e4c50b2f13f806b92d26bccd29862f0c (diff)
Merge changes from trunk so that OSGi remote services can be run with Equinox and Felix over tribes's multicast. This introduces a dependency on tuscany maven-bundle-plugin 1.0.5-SNAPSHOT and we should release it with M4.
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@832215 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'branches/sca-java-2.0-M4/modules/endpoint-tribes/src/main/java')
-rw-r--r--branches/sca-java-2.0-M4/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/branches/sca-java-2.0-M4/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java b/branches/sca-java-2.0-M4/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
index 3a703bca62..ac2933564e 100644
--- a/branches/sca-java-2.0-M4/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
+++ b/branches/sca-java-2.0-M4/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
@@ -354,10 +354,12 @@ public class ReplicatedEndpointRegistry implements EndpointRegistry, LifeCycleLi
public void entryAdded(Object key, Object value) {
MapEntry entry = (MapEntry)value;
+ Endpoint newEp = (Endpoint)entry.getValue();
if (!isLocal(entry)) {
logger.info(id + " Remote endpoint added: " + entry.getValue());
+ newEp.setRemote(true);
}
- Endpoint newEp = (Endpoint)entry.getValue();
+ newEp.setExtensionPointRegistry(registry);
for (EndpointListener listener : listeners) {
listener.endpointAdded(newEp);
}