[
https://issues.apache.org/jira/browse/PROTON-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alan Conway closed PROTON-1592.
-------------------------------
Resolution: Won't Fix
The issue is due to the unfinished status of the transaction API. Until we
clarify and finalize that behavior there is some danger of changes. The example
has been fixed to work before and after the change, which is the best we can do
for now.
> [proton-python] accessing properties of event.receiver in on_link_opened
> throws exception
> -----------------------------------------------------------------------------------------
>
> Key: PROTON-1592
> URL: https://issues.apache.org/jira/browse/PROTON-1592
> Project: Qpid Proton
> Issue Type: Bug
> Components: python-binding
> Reporter: Jiri Daněk
> Assignee: Alan Conway
> Labels: regression
> Fix For: proton-c-0.18.0
>
>
> Apply the following patch to the {{tx-recv.py}} example
> {code}
> diff --git a/examples/python/tx_recv.py b/examples/python/tx_recv.py
> index 4baddcf5..54f3b489 100755
> --- a/examples/python/tx_recv.py
> +++ b/examples/python/tx_recv.py
> @@ -40,6 +40,9 @@ class TxRecv(MessagingHandler, TransactionHandler):
> self.container.declare_transaction(self.conn, handler=self)
> self.transaction = None
>
> + def on_link_opened(self, event):
> + event.receiver.drain_mode = True
> +
> def on_message(self, event):
> print(event.message.body)
> self.transaction.accept(event.delivery)
> {code}
> Now run first {{tx_send.py}}, then this {{tx_recv.py}}. The second command
> throws exception
> {noformat}
> $ LD_LIBRARY_PATH=`pwd`/lib64 PYTHONPATH=`pwd`/lib64/proton/bindings/python
> python ../examples/python/tx_recv.py
> Traceback (most recent call last):
> File "../examples/python/tx_recv.py", line 79, in <module>
> Container(TxRecv(opts.address, opts.messages, opts.batch_size)).run()
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/reactor.py",
> line 148, in run
> while self.process(): pass
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/reactor.py",
> line 174, in process
> self._check_errors()
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/reactor.py",
> line 170, in _check_errors
> _compat.raise_(exc, value, tb)
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/__init__.py",
> line 4068, in dispatch
> ev.dispatch(self.handler)
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/__init__.py",
> line 3977, in dispatch
> result = dispatch(handler, type.method, self)
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/__init__.py",
> line 3857, in dispatch
> return handler.on_unhandled(method, *args)
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/reactor.py",
> line 876, in on_unhandled
> event.dispatch(handler)
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/__init__.py",
> line 3980, in dispatch
> self.dispatch(h, type)
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/__init__.py",
> line 3977, in dispatch
> result = dispatch(handler, type.method, self)
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/__init__.py",
> line 3855, in dispatch
> return m(*args)
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/handlers.py",
> line 298, in on_link_remote_open
> self.on_link_opened(event)
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/handlers.py",
> line 313, in on_link_opened
> dispatch(self.delegate, 'on_link_opened', event)
> File
> "/home/jdanek/Work/repos/qpid-proton/install/lib64/proton/bindings/python/proton/__init__.py",
> line 3855, in dispatch
> return m(*args)
> File "../examples/python/tx_recv.py", line 44, in on_link_opened
> event.receiver.drain_mode = True
> AttributeError: 'NoneType' object has no attribute 'drain_mode'
> {noformat}
> To see this is a regression, repeat now with python-qpid-proton 0.17.0 from
> Pypi. With this previous release, there is success.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
