Repository: qpid-proton Updated Branches: refs/heads/master 5b227bbfb -> 530cab026
PROTON-1120: ensure messages are settled locally Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/530cab02 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/530cab02 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/530cab02 Branch: refs/heads/master Commit: 530cab0264dac6f503772fd8ac672e5977a95f94 Parents: 5b227bb Author: Gordon Sim <[email protected]> Authored: Mon Feb 1 23:09:52 2016 +0000 Committer: Gordon Sim <[email protected]> Committed: Mon Feb 1 23:10:05 2016 +0000 ---------------------------------------------------------------------- proton-c/bindings/python/proton/utils.py | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/530cab02/proton-c/bindings/python/proton/utils.py ---------------------------------------------------------------------- diff --git a/proton-c/bindings/python/proton/utils.py b/proton-c/bindings/python/proton/utils.py index 5094285..b97f470 100644 --- a/proton-c/bindings/python/proton/utils.py +++ b/proton-c/bindings/python/proton/utils.py @@ -76,6 +76,8 @@ class BlockingSender(BlockingLink): def send(self, msg, timeout=False, error_states=None): delivery = self.link.send(msg) self.connection.wait(lambda: _is_settled(delivery), msg="Sending on sender %s" % self.link.name, timeout=timeout) + if delivery.link.snd_settle_mode != Link.SND_SETTLED: + delivery.settle() bad = error_states if bad is None: bad = [Delivery.REJECTED, Delivery.RELEASED] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
