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