Repository: qpid-proton
Updated Branches:
  refs/heads/master dcec9ff06 -> 0028c1c31


Changed name of method from fetch to receive


Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/0028c1c3
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/0028c1c3
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/0028c1c3

Branch: refs/heads/master
Commit: 0028c1c3159bdb668c1a119ec0bdbf5e24e7ff65
Parents: dcec9ff
Author: Gordon Sim <[email protected]>
Authored: Thu Jan 29 20:04:14 2015 +0000
Committer: Gordon Sim <[email protected]>
Committed: Thu Jan 29 20:04:14 2015 +0000

----------------------------------------------------------------------
 proton-c/bindings/python/proton/utils.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/0028c1c3/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 d2ece79..9349bb9 100644
--- a/proton-c/bindings/python/proton/utils.py
+++ b/proton-c/bindings/python/proton/utils.py
@@ -109,12 +109,12 @@ class BlockingReceiver(BlockingLink):
         if credit: receiver.flow(credit)
         self.fetcher = fetcher
 
-    def fetch(self, timeout=False):
+    def receive(self, timeout=False):
         if not self.fetcher:
-            raise Exception("Can't call fetch on this receiver as a handler 
was provided")
+            raise Exception("Can't call receive on this receiver as a handler 
was provided")
         if not self.link.credit:
             self.link.flow(1)
-        self.connection.wait(lambda: self.fetcher.has_message, msg="Fetching 
on receiver %s" % self.link.name, timeout=timeout)
+        self.connection.wait(lambda: self.fetcher.has_message, msg="Receiving 
on receiver %s" % self.link.name, timeout=timeout)
         return self.fetcher.pop()
 
     def accept(self):


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to