diff options
| author | Bhupendra Bhusman Bhardwaj <bhupendrab@apache.org> | 2007-02-07 11:27:15 +0000 |
|---|---|---|
| committer | Bhupendra Bhusman Bhardwaj <bhupendrab@apache.org> | 2007-02-07 11:27:15 +0000 |
| commit | 74efb78118ccbac87face808290e2ff1e1d40f1a (patch) | |
| tree | 741a03949986e5e836c149aef40ea73cbae39da0 /qpid/java/common | |
| parent | e2d6d856396fc2faef0f21785d09141ba84ba4f2 (diff) | |
| download | qpid-python-74efb78118ccbac87face808290e2ff1e1d40f1a.tar.gz | |
QPID-170
Management feature added - moving messages from one Queue to another
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@504507 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueAtomicSize.java | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueAtomicSize.java b/qpid/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueAtomicSize.java index c2d758611d..c4d7683a02 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueAtomicSize.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueAtomicSize.java @@ -55,4 +55,16 @@ public class ConcurrentLinkedQueueAtomicSize<E> extends ConcurrentLinkedQueue<E> return e; } + + @Override + public boolean remove(Object o) + { + if (super.remove(o)) + { + _size.decrementAndGet(); + return true; + } + + return false; + } } |