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/11 19:00:20 UTC
svn commit: r495314 -
/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java
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));
}