summaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
Diffstat (limited to 'python')
-rwxr-xr-xpython/commands/qpid-queue-stats4
1 files changed, 3 insertions, 1 deletions
diff --git a/python/commands/qpid-queue-stats b/python/commands/qpid-queue-stats
index 356a1d2d8d..3b8a0dcb19 100755
--- a/python/commands/qpid-queue-stats
+++ b/python/commands/qpid-queue-stats
@@ -79,7 +79,7 @@ class BrokerManager(Console):
if len(self.filter) > 0 :
match = False
-
+
for x in self.filter:
if x.match(name):
match = True
@@ -103,12 +103,14 @@ class BrokerManager(Console):
(deltaTime / 1000000000.0)
print "%-41s%10.2f%11d%13.2f%13.2f" % \
(name, deltaTime / 1000000000, record.msgDepth, enqueueRate, dequeueRate)
+ sys.stdout.flush()
def Display (self):
self.session.bindClass("org.apache.qpid.broker", "queue")
print "Queue Name Sec Depth Enq Rate Deq Rate"
print "========================================================================================"
+ sys.stdout.flush()
try:
while True:
sleep (1)