qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rob...@apache.org
Subject svn commit: r941376 - /qpid/branches/0.5.x-dev/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
Date Wed, 05 May 2010 16:41:14 GMT
Author: robbie
Date: Wed May  5 16:41:14 2010
New Revision: 941376

URL: http://svn.apache.org/viewvc?rev=941376&view=rev
Log:
QPID-2568: move the null into 'dispose' instead of 'delete'

Modified:
    qpid/branches/0.5.x-dev/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java

Modified: qpid/branches/0.5.x-dev/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
URL: http://svn.apache.org/viewvc/qpid/branches/0.5.x-dev/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java?rev=941376&r1=941375&r2=941376&view=diff
==============================================================================
--- qpid/branches/0.5.x-dev/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
(original)
+++ qpid/branches/0.5.x-dev/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
Wed May  5 16:41:14 2010
@@ -299,6 +299,9 @@ public class QueueEntryImpl implements Q
         if(delete())
         {
             getMessage().decrementReference(storeContext);
+            
+            //Ensure we can't hang on to the message;
+            _message = null;
         }
     }
 
@@ -388,9 +391,6 @@ public class QueueEntryImpl implements Q
         {
             _queueEntryList.advanceHead();            
             
-            //Ensure we can't hang on to the message;
-            _message = null;
-            
             return true;
         }
         else



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message