PROTON-1592: [python] restore original tx_recv.py example Previous commit introduced reproducer code into the example by mistake. The original example works as-is.
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/72b7ea05 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/72b7ea05 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/72b7ea05 Branch: refs/heads/master Commit: 72b7ea0508e94aae3e5d9470293bc5c7e8250a45 Parents: f76f289 Author: Alan Conway <acon...@redhat.com> Authored: Thu Oct 12 10:45:51 2017 -0400 Committer: Alan Conway <acon...@redhat.com> Committed: Fri Oct 13 14:44:56 2017 +0100 ---------------------------------------------------------------------- examples/python/tx_recv.py | 6 ------ 1 file changed, 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/72b7ea05/examples/python/tx_recv.py ---------------------------------------------------------------------- diff --git a/examples/python/tx_recv.py b/examples/python/tx_recv.py index 7c0b7cc..4baddcf 100755 --- a/examples/python/tx_recv.py +++ b/examples/python/tx_recv.py @@ -40,12 +40,6 @@ class TxRecv(MessagingHandler, TransactionHandler): self.container.declare_transaction(self.conn, handler=self) self.transaction = None - def on_link_opened(self, event): - # NOTE: a transactional client opens an internal sender link for transaction commands, - # which we want to ignore. - if event.receiver: - event.receiver.drain_mode = True - def on_message(self, event): print(event.message.body) self.transaction.accept(event.delivery) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
