From bed459b4f59e2e9930a9d4c7d906616b9dff2571 Mon Sep 17 00:00:00 2001 From: Ted Ross Date: Mon, 24 Nov 2008 19:51:03 +0000 Subject: QPID-1484 - qpid-printevents now handles connection loss/reconnect git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720276 13f79535-47bb-0310-9956-ffa450edef68 --- python/commands/qpid-printevents | 18 ++++++++++++++---- 1 file changed, 14 insertions(+), 4 deletions(-) (limited to 'python') diff --git a/python/commands/qpid-printevents b/python/commands/qpid-printevents index f27eec04f1..0c1b618a1f 100755 --- a/python/commands/qpid-printevents +++ b/python/commands/qpid-printevents @@ -23,13 +23,20 @@ import os import optparse import sys import socket -import time +from time import time, strftime, gmtime, sleep from qmf.console import Console, Session class EventConsole(Console): def event(self, broker, event): print event + def brokerConnected(self, broker): + print strftime("%c", gmtime(time())), "NOTIC qpid-printevents:brokerConnected broker=%s" % broker.getUrl() + + def brokerDisconnected(self, broker): + print strftime("%c", gmtime(time())), "NOTIC qpid-printevents:brokerDisconnected broker=%s" % broker.getUrl() + + ## ## Main Program ## @@ -48,14 +55,17 @@ ex: localhost, 10.1.1.7:10000, broker-host:10000, guest/guest@localhost arguments.append("localhost") console = EventConsole() - session = Session(console, rcvObjects=False, rcvHeartbeats=False) + session = Session(console, rcvObjects=False, rcvHeartbeats=False, manageConnections=True) + brokers = [] for host in arguments: - session.addBroker(host) + brokers.append(session.addBroker(host)) try: while (True): - time.sleep(10) + sleep(10) except KeyboardInterrupt: + for broker in brokers: + session.delBroker(broker) print sys.exit(0) -- cgit v1.2.1