added get_error

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@933920 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 24 insertions, 0 deletions

diff --git a/python/qpid/messaging/endpoints.py b/python/qpid/messaging/endpoints.py
index e2602bfc15..30165438c0 100644
--- a/python/qpid/messaging/endpoints.py
+++ b/python/qpid/messaging/endpoints.py
@@ -177,6 +177,9 @@ class Connection:
       self._condition.gc()
       raise self.error
 
+  def get_error(self):
+    return self.error
+
   def _ewait(self, predicate, timeout=None):
     result = self._wait(lambda: self.error or predicate(), timeout)
     self.check_error()
@@ -513,6 +516,13 @@ class Session:
     if self.error:
       raise self.error
 
+  def get_error(self):
+    err = self.connection.get_error()
+    if err:
+      return err
+    else:
+      return self.error
+
   def _ewait(self, predicate, timeout=None):
     result = self.connection._ewait(lambda: self.error or predicate(), timeout)
     self.check_error()
@@ -710,6 +720,13 @@ class Sender:
     if self.error:
       raise self.error
 
+  def get_error(self):
+    err = self.session.get_error()
+    if err:
+      return err
+    else:
+      return self.error
+
   def _ewait(self, predicate, timeout=None):
     result = self.session._ewait(lambda: self.error or predicate(), timeout)
     self.check_error()
@@ -853,6 +870,13 @@ class Receiver(object):
     if self.error:
       raise self.error
 
+  def get_error(self):
+    err = self.session.get_error()
+    if err:
+      return err
+    else:
+      return self.error
+
   def _ewait(self, predicate, timeout=None):
     result = self.session._ewait(lambda: self.error or predicate(), timeout)
     self.check_error()