(self, event)
| 41 | self.transaction = None |
| 42 | |
| 43 | def on_message(self, event): |
| 44 | print(event.message.body) |
| 45 | self.transaction.accept(event.delivery) |
| 46 | self.current_batch += 1 |
| 47 | if self.current_batch == self.batch_size: |
| 48 | self.transaction.commit() |
| 49 | self.transaction = None |
| 50 | |
| 51 | def on_transaction_declared(self, event): |
| 52 | self.receiver.flow(self.batch_size) |