(self)
| 68 | self.send() |
| 69 | |
| 70 | def send(self): |
| 71 | while self.sender.credit and not self.records.empty(): |
| 72 | if not self.keep_sending(): |
| 73 | return |
| 74 | record = self.records.get(False) |
| 75 | id = record['id'] |
| 76 | self.sender.send(Message(id=id, durable=True, body=record['description']), tag=str(id)) |
| 77 | self.sent += 1 |
| 78 | print("sent message %s" % id) |
| 79 | self.request_records() |
| 80 | |
| 81 | def on_settled(self, event): |
| 82 | id = int(event.delivery.tag) |