You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2007/01/29 12:11:30 UTC

svn commit: r501010 - /incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java

Author: rgreig
Date: Mon Jan 29 03:11:29 2007
New Revision: 501010

URL: http://svn.apache.org/viewvc?view=rev&rev=501010
Log:
QPID-322 : Patch supplied by Rob Godfrey - Message reference count not being incremented when message added to UnacknowledgeMap



Modified:
    incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java

Modified: incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java?view=diff&rev=501010&r1=501009&r2=501010
==============================================================================
--- incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java (original)
+++ incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java Mon Jan 29 03:11:29 2007
@@ -39,6 +39,7 @@
         this.message = message;
         this.consumerTag = consumerTag;
         this.deliveryTag = deliveryTag;
+        message.incrementReference();
     }
 
     public void discard(StoreContext storeContext) throws AMQException