diff options
| -rw-r--r-- | extras/qmf/src/py/qmf/console.py | 6 | ||||
| -rwxr-xr-x | tools/src/py/qpid-printevents | 4 |
2 files changed, 10 insertions, 0 deletions
diff --git a/extras/qmf/src/py/qmf/console.py b/extras/qmf/src/py/qmf/console.py index 45a8a61fa0..430ca60b98 100644 --- a/extras/qmf/src/py/qmf/console.py +++ b/extras/qmf/src/py/qmf/console.py @@ -53,6 +53,10 @@ class Console: """ Invoked when a connection is established to a broker """ pass + def brokerConnectionFailed(self, broker): + """ Invoked when a connection to a broker fails """ + pass + def brokerDisconnected(self, broker): """ Invoked when the connection to a broker is lost """ pass @@ -2510,6 +2514,8 @@ class Broker(Thread): except Exception, e: self.error = "Exception during connection setup: %s - %s" % (e.__class__.__name__, e) self.conn_exc = e + if self.session.console: + self.session.console.brokerConnectionFailed(self) return False # connection failed def _updateAgent(self, obj): diff --git a/tools/src/py/qpid-printevents b/tools/src/py/qpid-printevents index 260d0df79d..2be2f0be8b 100755 --- a/tools/src/py/qpid-printevents +++ b/tools/src/py/qpid-printevents @@ -37,6 +37,10 @@ class EventConsole(Console): print strftime("%c", gmtime(time())), "NOTIC qpid-printevents:brokerConnected broker=%s" % broker.getUrl() sys.stdout.flush() + def brokerConnectionFailed(self, broker): + print strftime("%c", gmtime(time())), "NOTIC qpid-printevents:brokerConnectionFailed broker=%s %s" % (broker.getUrl(), str(broker.conn_exc)) + sys.stdout.flush() + def brokerDisconnected(self, broker): print strftime("%c", gmtime(time())), "NOTIC qpid-printevents:brokerDisconnected broker=%s" % broker.getUrl() sys.stdout.flush() |