summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRobert Greig <rgreig@apache.org>2007-01-11 18:00:19 +0000
committerRobert Greig <rgreig@apache.org>2007-01-11 18:00:19 +0000
commit7d80d0a528b9b9524cc338cfaecc565b6dc9d720 (patch)
treeddaf2d2288d4ccc5ecdd42d5a35579ac4990aa11
parentd7d88effebf7f17394e62d2a51b252ca6af74c47 (diff)
downloadqpid-python-7d80d0a528b9b9524cc338cfaecc565b6dc9d720.tar.gz
QPID-32 Fix for non-persistent message sending
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@495314 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java b/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java
index d87554524f..2adedea8e0 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java
@@ -187,7 +187,7 @@ public class LocalTransactionalContext implements TransactionalContext
_ackOp = null;
}
- if (_messageDelivered)
+ if (_messageDelivered && _inTran)
{
_txnBuffer.enlist(new StoreMessageOperation(_messageStore));
}