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 | b37d5db6ef5e5e9363a1e791dcf9a419bc348bb1 (patch) | |
| tree | 83d4b469a2fe4b7876d2bc787857e0984bf0f94e /java/common | |
| parent | 020a924c742b185ef5360108985460f0155eb671 (diff) | |
| download | qpid-python-b37d5db6ef5e5e9363a1e791dcf9a419bc348bb1.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/qpid@504507 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueAtomicSize.java | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueAtomicSize.java b/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueAtomicSize.java index c2d758611d..c4d7683a02 100644 --- a/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueAtomicSize.java +++ b/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; + } } |