Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-06 01:59:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Reduce contention by using an Atomic Reference.

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@633570 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2008-03-04 17:52:14 +00:00
parent 1c8cfd9cfe
commit c84e58a948
1 changed files with 7 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
activemq-core/src/main/java/org/apache/activemq/broker/MutableBrokerFilter.java
View File

@ -19,6 +19,8 @@ package org.apache.activemq.broker;
import java.net.URI; import java.net.URI;
import java.util.Map; import java.util.Map;
import java.util.Set; import java.util.Set;
import java.util.concurrent.atomic.AtomicReference;
import org.apache.activemq.broker.region.Destination; import org.apache.activemq.broker.region.Destination;
import org.apache.activemq.broker.region.MessageReference; import org.apache.activemq.broker.region.MessageReference;
import org.apache.activemq.broker.region.Subscription; import org.apache.activemq.broker.region.Subscription;
@ -49,30 +51,25 @@ import org.apache.activemq.kaha.Store;
*/ */
public class MutableBrokerFilter implements Broker { public class MutableBrokerFilter implements Broker {
private Broker next; private AtomicReference<Broker> next = new AtomicReference<Broker>();
private final Object mutext = new Object();
public MutableBrokerFilter(Broker next) { public MutableBrokerFilter(Broker next) {
this.next = next; this.next.set(next);
} }
public Broker getAdaptor(Class type) { public Broker getAdaptor(Class type) {
if (type.isInstance(this)) { if (type.isInstance(this)) {
return this; return this;
} }
return next.getAdaptor(type); return next.get().getAdaptor(type);
} }
public Broker getNext() { public Broker getNext() {
synchronized (mutext) { return next.get();
return next;
}
} }
public void setNext(Broker next) { public void setNext(Broker next) {
synchronized (mutext) { this.next.set(next);
this.next = next;
}
} }
public Map<ActiveMQDestination, Destination> getDestinationMap() { public Map<ActiveMQDestination, Destination> getDestinationMap() {