From 3b80f903b6174b4346d7d7b537d783f628fe28d6 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Fri, 21 Sep 2007 15:13:52 +0000 Subject: Moved c++ over to using the same preview file for 0-10 work as java. Removed all channel class related code from broker as a result. Did the same for some python tests I missed earlier. Renamed ChannelAdapter to ChannelHandler. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@578167 13f79535-47bb-0310-9956-ffa450edef68 --- python/tests_0-10/dtx.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) (limited to 'python/tests_0-10/dtx.py') diff --git a/python/tests_0-10/dtx.py b/python/tests_0-10/dtx.py index 000eddff21..ce6e467e0a 100644 --- a/python/tests_0-10/dtx.py +++ b/python/tests_0-10/dtx.py @@ -461,8 +461,11 @@ class DtxTests(TestBase): channel2.dtx_demarcation_select() channel2.dtx_demarcation_start(xid=tx) - channel2.message_get(queue="dummy", destination="dummy") + channel2.message_subscribe(queue="dummy", destination="dummy", confirm_mode=1) + channel2.message_flow(destination="dummy", unit=0, value=1) + channel2.message_flow(destination="dummy", unit=1, value=0xFFFFFFFF) self.client.queue("dummy").get(timeout=1).complete() + channel2.message_cancel(destination="dummy") channel2.message_transfer(content=Content(properties={'routing_key':"dummy"}, body="whatever")) channel2.session_close() @@ -589,8 +592,11 @@ class DtxTests(TestBase): def swap(self, channel, src, dest): #consume from src: - channel.message_get(destination="temp-swap", queue=src) + channel.message_subscribe(destination="temp-swap", queue=src, confirm_mode=1) + channel.message_flow(destination="temp-swap", unit=0, value=1) + channel.message_flow(destination="temp-swap", unit=1, value=0xFFFFFFFF) msg = self.client.queue("temp-swap").get(timeout=1) + channel.message_cancel(destination="temp-swap") msg.complete(); #re-publish to dest -- cgit v1.2.1