You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2014/12/12 18:47:59 UTC

qpid-proton git commit: removed dead _popped method and added a transport property to protocol events, endpoints, and deliveries

Repository: qpid-proton
Updated Branches:
  refs/heads/master 7ed445601 -> 5b1eaa0ee


removed dead _popped method and added a transport property to protocol events, endpoints, and deliveries


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

Branch: refs/heads/master
Commit: 5b1eaa0ee60702ff6eb8ab37ffe743aa8f4d92e7
Parents: 7ed4456
Author: Rafael Schloming <rh...@alum.mit.edu>
Authored: Fri Dec 12 12:47:42 2014 -0500
Committer: Rafael Schloming <rh...@alum.mit.edu>
Committed: Fri Dec 12 12:47:42 2014 -0500

----------------------------------------------------------------------
 proton-c/bindings/python/proton/__init__.py | 20 +++++++++++++++++---
 1 file changed, 17 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/5b1eaa0e/proton-c/bindings/python/proton/__init__.py
----------------------------------------------------------------------
diff --git a/proton-c/bindings/python/proton/__init__.py b/proton-c/bindings/python/proton/__init__.py
index ae520f6..543f3da 100644
--- a/proton-c/bindings/python/proton/__init__.py
+++ b/proton-c/bindings/python/proton/__init__.py
@@ -2201,6 +2201,10 @@ class Endpoint(object):
   def _get_remote_cond_impl(self):
       assert False, "Subclass must override this!"
 
+  @property
+  def transport(self):
+    return self.connection.transport
+
 class Condition:
 
   def __init__(self, name, description=None, info=None):
@@ -2882,6 +2886,10 @@ class Delivery(Wrapper):
   def connection(self):
     return self.session.connection
 
+  @property
+  def transport(self):
+    return self.connection.transport
+
 class TransportException(ProtonException):
   pass
 
@@ -3311,9 +3319,6 @@ class EventBase(object):
     self.context = context
     self.type = type
 
-  def _popped(self, collector):
-    pass
-
   def dispatch(self, handler):
     return dispatch(handler, self.type.method, self)
 
@@ -3360,6 +3365,15 @@ class Event(EventBase):
     return dispatch(handler, self.type.method, self)
 
   @property
+  def transport(self):
+    if self.clazz == "pn_transport":
+      return self.context
+    elif self.clazz in ["pn_connection", "pn_session", "pn_link", "pn_delivery"]:
+      return self.context.transport
+    else:
+      return None
+
+  @property
   def connection(self):
     if self.clazz == "pn_connection":
       return self.context


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org