Repository: qpid-proton Updated Branches: refs/heads/0.12.x 8dbbeda61 -> 5dc39f8fc
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/5dc39f8f Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/5dc39f8f Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/5dc39f8f Branch: refs/heads/0.12.x Commit: 5dc39f8fc4e89f1e45ca42bda961260db458e128 Parents: 8dbbeda Author: Gordon Sim <[email protected]> Authored: Mon Feb 1 23:09:52 2016 +0000 Committer: Gordon Sim <[email protected]> Committed: Tue Feb 2 09:27:33 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/5dc39f8f/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]
