From faeceaf81e73b23260d32503bc09e87f6ed2e735 Mon Sep 17 00:00:00 2001 From: Kenneth Anthony Giusti Date: Tue, 26 Jan 2010 19:38:05 +0000 Subject: QPID-2261: checkpoint qmfv2 python api git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903382 13f79535-47bb-0310-9956-ffa450edef68 --- python/qmf2/tests/events.py | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) (limited to 'python/qmf2/tests/events.py') diff --git a/python/qmf2/tests/events.py b/python/qmf2/tests/events.py index b2d934728d..171cb80aaa 100644 --- a/python/qmf2/tests/events.py +++ b/python/qmf2/tests/events.py @@ -22,6 +22,7 @@ import logging from threading import Thread, Event import qpid.messaging +from qpid.harness import Skipped from qmf2.common import (Notifier, SchemaObjectClass, SchemaClassId, SchemaProperty, qmfTypes, SchemaMethod, QmfQuery, QmfData, QmfQueryPredicate, SchemaEventClass, @@ -93,7 +94,11 @@ class _agentApp(Thread): self.broker_url.port, self.broker_url.user, self.broker_url.password) - conn.connect() + try: + conn.connect() + except qpid.messaging.ConnectError, e: + raise Skipped(e) + self.agent.set_connection(conn) counter = 1 @@ -150,12 +155,18 @@ class BaseTest(unittest.TestCase): self.broker.port, self.broker.user, self.broker.password) - self.conn.connect() + try: + self.conn.connect() + except qpid.messaging.ConnectError, e: + raise Skipped(e) + self.console.addConnection(self.conn) # find the agents for aname in ["agent1", "agent2"]: + print("!!! finding aname=%s (%s)" % (aname, time.time())) agent = self.console.find_agent(aname, timeout=3) + print("!!! agent=%s aname=%s (%s)" % (agent, aname, time.time())) self.assertTrue(agent and agent.get_name() == aname) # now wait for events -- cgit v1.2.1