Skip to content

Commit

Permalink
Assume target queue exists when getting status.
Browse files Browse the repository at this point in the history
If the queue does not exist, the command will fail with an error.
  • Loading branch information
dougbarth committed Jan 30, 2009
1 parent f63f0e6 commit fa1c007
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion bin/amqp-statq
Expand Up @@ -15,7 +15,7 @@ class QueueStatCommand < AmqpUtils::Command
@queues = ARGV

@queues.each do |queue|
MQ.new.queue(queue).status do |size, consumers|
MQ.new.queue(queue, :passive => true).status do |size, consumers|
puts "Queue <#{queue}>: #{size} message(s), #{consumers} consumer(s)"

@queues.delete(queue)
Expand Down

0 comments on commit fa1c007

Please sign in to comment.