(self, channel, method, header, body)
| 850 | self.stop() |
| 851 | |
| 852 | def on_message(self, channel, method, header, body): |
| 853 | self.assertIsInstance(method, spec.Basic.Deliver) |
| 854 | self.assertEqual(body, as_bytes(self.msg_body)) |
| 855 | self.channel.basic_ack(method.delivery_tag) |
| 856 | self.channel.basic_cancel(self.ctag, callback=self.on_cancelled) |
| 857 | |
| 858 | |
| 859 | class TestZ_PublishAndConsumeBig(BoundQueueTestCase, AsyncAdapters): # pylint: disable=C0103 |
nothing calls this directly
no test coverage detected