Author: bhupendrab
Date: Tue Jan 30 07:05:28 2007
New Revision: 501412
URL: http://svn.apache.org/viewvc?view=rev&rev=501412
Log:
fixed the null pointer, which occurs when there are no messages in the queue
Modified:
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java
Modified:
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java?view=diff&rev=501412&r1=501411&r2=501412
==============================================================================
---
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java
(original)
+++
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java
Tue Jan 30 07:05:28 2007
@@ -243,8 +243,8 @@
if (msg != null)
{
msg.dequeue(storeContext, _queue);
- }
- _totalMessageSize.getAndAdd(-msg.getSize());
+ _totalMessageSize.getAndAdd(-msg.getSize());
+ }
}
public synchronized long clearAllMessages(StoreContext storeContext)
throws AMQException
