(self, channel, method, header, body)
| 874 | self.stop() |
| 875 | |
| 876 | def on_message(self, channel, method, header, body): |
| 877 | self.assertIsInstance(method, spec.Basic.Deliver) |
| 878 | self.assertEqual(body, as_bytes(self.msg_body)) |
| 879 | self.channel.basic_ack(method.delivery_tag) |
| 880 | self.channel.basic_cancel(self.ctag, callback=self.on_cancelled) |
| 881 | |
| 882 | |
| 883 | class TestZ_PublishAndGet(BoundQueueTestCase, AsyncAdapters): # pylint: disable=C0103 |
nothing calls this directly
no test coverage detected