(self, frame)
| 534 | callback=self.on_queue_declared) |
| 535 | |
| 536 | def on_queue_declared(self, frame): |
| 537 | for i in range(0, 100): |
| 538 | msg_body = '{}:{}:{}'.format(self.__class__.__name__, i, time_now()) |
| 539 | self.channel.basic_publish('', self.queue_name, msg_body) |
| 540 | self.ctag = self.channel.basic_consume(self.queue_name, |
| 541 | self.on_message, |
| 542 | auto_ack=True) |
| 543 | |
| 544 | def on_message(self, _channel, _frame, _header, body): |
| 545 | self.channel.basic_cancel(self.ctag, callback=self.on_cancel) |
nothing calls this directly
no test coverage detected