qpid_tests/broker_0_8/tx.py [66:93]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        for q in [queue_a, queue_b, queue_c]:
            try:
                extra = q.get(timeout=self.recv_timeout_negative())
                self.fail("Got unexpected message: " + extra.content.body)
            except Empty: None

        channel.tx_rollback()

        #check results
        for i in range(1, 5):
            msg = queue_a.get(timeout=self.recv_timeout())
            self.assertEqual("Message %d" % i, msg.content.body)

        msg = queue_b.get(timeout=self.recv_timeout())
        self.assertEqual("Message 6", msg.content.body)

        msg = queue_c.get(timeout=self.recv_timeout())
        self.assertEqual("Message 7", msg.content.body)

        for q in [queue_a, queue_b, queue_c]:
            try:
                extra = q.get(timeout=self.recv_timeout_negative())
                self.fail("Got unexpected message: " + extra.content.body)
            except Empty: None

        #cleanup
        channel.basic_ack(delivery_tag=0, multiple=True)
        channel.tx_commit()
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



qpid_tests/broker_0_8/tx.py [102:129]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        for q in [queue_a, queue_b, queue_c]:
            try:
                extra = q.get(timeout=self.recv_timeout_negative())
                self.fail("Got unexpected message: " + extra.content.body)
            except Empty: None

        channel.tx_rollback()

        #check results
        for i in range(1, 5):
            msg = queue_a.get(timeout=self.recv_timeout())
            self.assertEqual("Message %d" % i, msg.content.body)

        msg = queue_b.get(timeout=self.recv_timeout())
        self.assertEqual("Message 6", msg.content.body)

        msg = queue_c.get(timeout=self.recv_timeout())
        self.assertEqual("Message 7", msg.content.body)

        for q in [queue_a, queue_b, queue_c]:
            try:
                extra = q.get(timeout=self.recv_timeout_negative())
                self.fail("Got unexpected message: " + extra.content.body)
            except Empty: None

        #cleanup
        channel.basic_ack(delivery_tag=0, multiple=True)
        channel.tx_commit()
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -