Author: rgreig
Date: Thu Jan 11 10:00:19 2007
New Revision: 495314

URL: http://svn.apache.org/viewvc?view=rev&rev=495314
Log:
QPID-32 Fix for non-persistent message sending

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=495314&r1=495313&r2=495314
==============================================================================
--- 
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
 Thu Jan 11 10:00:19 2007
@@ -187,7 +187,7 @@
             _ackOp = null;
         }
 
-        if (_messageDelivered)
+        if (_messageDelivered && _inTran)
         {
             _txnBuffer.enlist(new StoreMessageOperation(_messageStore));
         }


Reply via email to