You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by dk...@apache.org on 2007/10/02 23:35:46 UTC
svn commit: r581393 -
/incubator/cxf/trunk/rt/core/src/main/java/org/apache/cxf/transport/MultipleEndpointObserver.java
Author: dkulp
Date: Tue Oct 2 14:35:45 2007
New Revision: 581393
URL: http://svn.apache.org/viewvc?rev=581393&view=rev
Log:
Make MultipleEndpointObserver threadsafe
Modified:
incubator/cxf/trunk/rt/core/src/main/java/org/apache/cxf/transport/MultipleEndpointObserver.java
Modified: incubator/cxf/trunk/rt/core/src/main/java/org/apache/cxf/transport/MultipleEndpointObserver.java
URL: http://svn.apache.org/viewvc/incubator/cxf/trunk/rt/core/src/main/java/org/apache/cxf/transport/MultipleEndpointObserver.java?rev=581393&r1=581392&r2=581393&view=diff
==============================================================================
--- incubator/cxf/trunk/rt/core/src/main/java/org/apache/cxf/transport/MultipleEndpointObserver.java (original)
+++ incubator/cxf/trunk/rt/core/src/main/java/org/apache/cxf/transport/MultipleEndpointObserver.java Tue Oct 2 14:35:45 2007
@@ -18,10 +18,10 @@
*/
package org.apache.cxf.transport;
-import java.util.ArrayList;
-import java.util.HashSet;
import java.util.List;
import java.util.Set;
+import java.util.concurrent.CopyOnWriteArrayList;
+import java.util.concurrent.CopyOnWriteArraySet;
import org.apache.cxf.Bus;
import org.apache.cxf.endpoint.Endpoint;
@@ -44,9 +44,9 @@
public static final String ENDPOINTS = "multipleEndpointObserver.endpoints";
protected Bus bus;
- protected List<Interceptor> bindingInterceptors = new ArrayList<Interceptor>();
- protected List<Interceptor> routingInterceptors = new ArrayList<Interceptor>();
- private Set<Endpoint> endpoints = new HashSet<Endpoint>();
+ protected List<Interceptor> bindingInterceptors = new CopyOnWriteArrayList<Interceptor>();
+ protected List<Interceptor> routingInterceptors = new CopyOnWriteArrayList<Interceptor>();
+ private Set<Endpoint> endpoints = new CopyOnWriteArraySet<Endpoint>();
public MultipleEndpointObserver(Bus bus) {
super();
@@ -106,24 +106,12 @@
return bindingInterceptors;
}
- public void setBindingInterceptors(List<Interceptor> bindingInterceptors) {
- this.bindingInterceptors = bindingInterceptors;
- }
-
public List<Interceptor> getRoutingInterceptors() {
return routingInterceptors;
}
- public void setRoutingInterceptors(List<Interceptor> routingInterceptors) {
- this.routingInterceptors = routingInterceptors;
- }
-
public Set<Endpoint> getEndpoints() {
return endpoints;
}
- public void setEndpoints(Set<Endpoint> endpoints) {
- this.endpoints = endpoints;
- }
-
}