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/12 16:05:33 UTC

svn commit: r495595 - /incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java

Author: rgreig
Date: Fri Jan 12 07:05:32 2007
New Revision: 495595

URL: http://svn.apache.org/viewvc?view=rev&rev=495595
Log:
QPID-32 : Persistence Optimisation

Modified:
    incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java

Modified: incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java?view=diff&rev=495595&r1=495594&r2=495595
==============================================================================
--- incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java (original)
+++ incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java Fri Jan 12 07:05:32 2007
@@ -135,6 +135,7 @@
         //we will need to create and enlist the op.
         if (_ackOp == null)
         {
+            beginTranIfNecessary();
             _ackOp = new TxAck(unacknowledgedMessageMap);
             _txnBuffer.enlist(_ackOp);
         }
@@ -182,6 +183,8 @@
         }
         if (_ackOp != null)
         {
+
+            _messageDelivered = true;
             _ackOp.consolidate();
             //already enlisted, after commit will reset regardless of outcome
             _ackOp = null;