qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From g...@apache.org
Subject qpid-proton git commit: PROTON-1120: ensure messages are settled locally
Date Tue, 02 Feb 2016 09:45:00 GMT
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 <gsim@redhat.com>
Authored: Mon Feb 1 23:09:52 2016 +0000
Committer: Gordon Sim <gsim@redhat.com>
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: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message