diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2008-01-08 12:59:01 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2008-01-08 12:59:01 +0000 |
| commit | 83f652ab8b9ee0ca3ec8fb6bb594156f75de1b1f (patch) | |
| tree | 069fb8b3b5bd9f7c0e9a804ea045ec349248407b | |
| parent | bac581489b453ccb7d0586474b7d75d8b259e003 (diff) | |
| download | qpid-python-83f652ab8b9ee0ca3ec8fb6bb594156f75de1b1f.tar.gz | |
QPID-499 : Patch to update the queue size statistics when the Active TTL process runs
Removed old single commented out code line from AMQSession.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@609961 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java | 2 | ||||
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 1 |
2 files changed, 2 insertions, 1 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java b/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java index bb0022ab4d..428418fee9 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java +++ b/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java @@ -224,6 +224,8 @@ public class ConcurrentSelectorDeliveryManager implements DeliveryManager AMQMessage msg = iter.next(); if(msg.expired(_queue)) { + // fixme: Currently we have to update the total byte size here for the data in the queue + _totalMessageSize.addAndGet(-msg.getSize()); _queue.dequeue(_reapingStoreContext,msg); msg.decrementReference(_reapingStoreContext); iter.remove(); diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java index 91df4f7d35..4277518f60 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java @@ -2136,7 +2136,6 @@ public class AMQSession extends Closeable implements Session, QueueSession, Topi amqd.getAMQQueueName(), // queue getTicket()); // ticket QueueDeclareOkHandler okHandler = new QueueDeclareOkHandler(); - //getProtocolHandler().syncWrite(queueDeclare, QueueDeclareOkBody.class); getProtocolHandler().writeCommandFrameAndWaitForReply(queueDeclare, okHandler); return okHandler._messageCount; |