Author: jonathan
Date: Mon Jan 10 13:48:35 2011
New Revision: 1057195
URL: http://svn.apache.org/viewvc?rev=1057195&view=rev
Log:
Prints connection error information.
Previously, connection errors were silently ignored.
Modified:
qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py
qpid/trunk/qpid/tools/src/py/qpid-printevents
Modified: qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py?rev=1057195&r1=1057194&r2=1057195&view=diff
==============================================================================
--- qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py (original)
+++ qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py Mon Jan 10 13:48:35 2011
@@ -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):
Modified: qpid/trunk/qpid/tools/src/py/qpid-printevents
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/tools/src/py/qpid-printevents?rev=1057195&r1=1057194&r2=1057195&view=diff
==============================================================================
--- qpid/trunk/qpid/tools/src/py/qpid-printevents (original)
+++ qpid/trunk/qpid/tools/src/py/qpid-printevents Mon Jan 10 13:48:35 2011
@@ -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()
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
