(self, event)
| 79 | self.request_records() |
| 80 | |
| 81 | def on_settled(self, event): |
| 82 | id = int(event.delivery.tag) |
| 83 | self.db.delete(id) |
| 84 | print("settled message %s" % id) |
| 85 | self.confirmed += 1 |
| 86 | if self.confirmed == self.target: |
| 87 | event.connection.close() |
| 88 | self.db.close() |
| 89 | |
| 90 | def on_disconnected(self, event): |
| 91 | self.db.reset() |