diff options
| author | Jonathan Robie <jonathan@apache.org> | 2011-01-10 13:48:35 +0000 |
|---|---|---|
| committer | Jonathan Robie <jonathan@apache.org> | 2011-01-10 13:48:35 +0000 |
| commit | de0bef9f28c6e6b2238405086e3e0177ed36901a (patch) | |
| tree | d4a69b1fe7a37496745250c191c2c0e4122290d9 /qpid/tools/src | |
| parent | 952a5c6c479aaa360f86800cad6d4a34516d95fa (diff) | |
| download | qpid-python-de0bef9f28c6e6b2238405086e3e0177ed36901a.tar.gz | |
Prints connection error information.
Previously, connection errors were silently ignored.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1057195 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/tools/src')
| -rwxr-xr-x | qpid/tools/src/py/qpid-printevents | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/qpid/tools/src/py/qpid-printevents b/qpid/tools/src/py/qpid-printevents index 260d0df79d..2be2f0be8b 100755 --- a/qpid/tools/src/py/qpid-printevents +++ b/qpid/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() |