summaryrefslogtreecommitdiff
path: root/qpid/python/tests/tx.py
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/python/tests/tx.py')
-rw-r--r--qpid/python/tests/tx.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/python/tests/tx.py b/qpid/python/tests/tx.py
index 55a5eaeade..0f6b4f5cd1 100644
--- a/qpid/python/tests/tx.py
+++ b/qpid/python/tests/tx.py
@@ -163,7 +163,8 @@ class TxTests(TestBase):
for i in range(1, 5):
msg = queue_a.get(timeout=1)
self.assertEqual("Message %d" % i, msg.body)
- msg.ok()
+
+ msg.ok(batchoffset=-3)
channel.message_consume(queue=name_b, destination="sub_b", no_ack=False)
queue_b = self.client.queue("sub_b")