You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2016/02/02 00:17:39 UTC
qpid-proton git commit: PROTON-1120: ensure messages are settled
locally
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 <gs...@redhat.com>
Authored: Mon Feb 1 23:09:52 2016 +0000
Committer: Gordon Sim <gs...@redhat.com>
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: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org