diff options
author | rfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68> | 2009-06-30 00:42:51 +0000 |
---|---|---|
committer | rfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68> | 2009-06-30 00:42:51 +0000 |
commit | 4b8f6c020fd9ad60d55a9644b568a7bd8fa89bfd (patch) | |
tree | e4a839884172432840b7fe5b75a6c080eba24de4 /java/sca/modules/endpoint-tribes | |
parent | 38b1af699e42b6c2bd69f15f4a68635b037ea032 (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/endpoint-tribes')
-rw-r--r-- | java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java | 9 |
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) {
|