summaryrefslogtreecommitdiffstats
path: root/java/sca/modules
diff options
context:
space:
mode:
authorrfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68>2009-06-30 00:42:51 +0000
committerrfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68>2009-06-30 00:42:51 +0000
commit4b8f6c020fd9ad60d55a9644b568a7bd8fa89bfd (patch)
treee4a839884172432840b7fe5b75a6c080eba24de4 /java/sca/modules
parent38b1af699e42b6c2bd69f15f4a68635b037ea032 (diff)
Remove the duplicate notifications
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@789513 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/sca/modules')
-rw-r--r--java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java9
1 files changed, 0 insertions, 9 deletions
diff --git a/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java b/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
index aecaba2b9e..61daa958e0 100644
--- a/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
+++ b/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
@@ -139,9 +139,6 @@ public class ReplicatedEndpointRegistry implements EndpointRegistry, LifeCycleLi
public void addEndpoint(Endpoint endpoint) {
map.put(endpoint.getURI(), endpoint);
- for (EndpointListener listener : listeners) {
- listener.endpointAdded(endpoint);
- }
logger.info("Add endpoint - " + endpoint);
}
@@ -251,9 +248,6 @@ public class ReplicatedEndpointRegistry implements EndpointRegistry, LifeCycleLi
public void removeEndpoint(Endpoint endpoint) {
map.remove(endpoint.getURI());
- for (EndpointListener listener : listeners) {
- listener.endpointRemoved(endpoint);
- }
logger.info("Remove endpoint - " + endpoint);
}
@@ -272,9 +266,6 @@ public class ReplicatedEndpointRegistry implements EndpointRegistry, LifeCycleLi
throw new IllegalArgumentException("Endpoint is not found: " + uri);
}
map.put(endpoint.getURI(), endpoint);
- for (EndpointListener listener : listeners) {
- listener.endpointUpdated(oldEndpoint, endpoint);
- }
}
public void entryAdded(Object key, Object value) {