NO-JIRA: add default handling for transport errors
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/8e3231d0 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/8e3231d0 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/8e3231d0 Branch: refs/heads/0.10.x Commit: 8e3231d0b4a01e0ec01ed7ef3363b0750dca80b5 Parents: 8fca85a Author: Gordon Sim <g...@redhat.com> Authored: Tue Aug 4 17:30:18 2015 +0100 Committer: Gordon Sim <g...@redhat.com> Committed: Tue Aug 4 17:44:11 2015 +0100 ---------------------------------------------------------------------- proton-c/bindings/python/proton/handlers.py | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/8e3231d0/proton-c/bindings/python/proton/handlers.py ---------------------------------------------------------------------- diff --git a/proton-c/bindings/python/proton/handlers.py b/proton-c/bindings/python/proton/handlers.py index 4288cf8..f4ad5a9 100644 --- a/proton-c/bindings/python/proton/handlers.py +++ b/proton-c/bindings/python/proton/handlers.py @@ -387,6 +387,23 @@ class MessagingHandler(Handler, Acking): self.handlers.append(EndpointStateHandler(peer_close_is_error, self)) self.handlers.append(IncomingMessageHandler(auto_accept, self)) self.handlers.append(OutgoingMessageHandler(auto_settle, self)) + self.fatal_conditions = ["amqp:unauthorized-access"] + + def on_transport_error(self, event): + """ + Called when some error is encountered with the transport over + which the AMQP connection is to be established. This includes + authentication errors as well as socket errors. + """ + if event.transport.condition: + if event.transport.condition.info: + logging.error("%s: %s" % (event.transport.condition.name, event.transport.condition.description, event.transport.condition.info)) + else: + logging.error("%s: %s" % (event.transport.condition.name, event.transport.condition.description)) + if event.transport.condition.name in self.fatal_conditions: + event.connection.close() + else: + logging.error("Unspecified transport error") def on_connection_error(self, event): """ --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
