svn commit: r585570 - /incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java

[ritchiem]

Author: ritchiem
Date: Wed Oct 17 09:48:01 2007
New Revision: 585570

URL: http://svn.apache.org/viewvc?rev=585570&view=rev
Log:
Update to AMQMessage to reset the deliveredToConsumer flag(false) when the 
message is released. This flag is now used by more than the immediate delivery. 
It is also used to understand if the message has been delivered so that we can 
tell the message should not be purged.

Modified:
    
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java

Modified: 
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java?rev=585570&r1=585569&r2=585570&view=diff
==============================================================================
--- 
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
 (original)
+++ 
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
 Wed Oct 17 09:48:01 2007
@@ -133,7 +133,7 @@
     public boolean isReferenced()
     {
         return _referenceCount.get() > 0;
-    }    
+    }
 
     /**
      * Used to iterate through all the body frames associated with this 
message. Will not keep all the data in memory
@@ -558,6 +558,7 @@
                 taken.set(false);
             }
 
+            _deliveredToConsumer = false;
             _takenMap.put(queue, taken);
             _takenBySubcriptionMap.put(queue, null);
         }
@@ -694,7 +695,10 @@
         return false;
     }
 
-    /** Called when this message is delivered to a consumer. (used to 
implement the 'immediate' flag functionality). */
+    /**
+     * Called when this message is delivered to a consumer. (used to implement 
the 'immediate' flag functionality).
+     * And for selector efficiency.
+     */
     public void setDeliveredToConsumer()
     {
         _deliveredToConsumer = true;