Contents

module Bunnish::Command
  module Count
    def self.run(argv, input_stream=$stdin, output_stream=$stdout)
      
      params = Bunnish.parse_opts(argv)
      
      host = params[:host]
      port = params[:port]
      user = params[:user]
      password = params[:password]
      durable = params[:durable]
      
      queue_name = argv.shift

      if queue_name.nil?
        Bunnish.logger.error("queue-name is not set")
        return 1
      end
      
      bunny = Bunny.new(:logging => false, :spec => '09', :host=>host, :port=>port, :user=>user, :pass=>password)
      
      # start a communication session with the amqp server
      bunny.start
      
      # create/get queue
      queue = bunny.queue(queue_name, :durable=>durable)
      
      # remain_count = queue.status[:message_count]
        
      output_stream.puts queue.status[:message_count]
      
      # Close client
      bunny.stop
      
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
bunnish-0.1.3	lib/bunnish/command/count.rb
bunnish-0.1.2	lib/bunnish/command/count.rb
bunnish-0.1.1	lib/bunnish/command/count.rb
bunnish-0.1.0	lib/bunnish/command/count.rb
bunnish-0.0.9	lib/bunnish/command/count.rb
bunnish-0.0.8	lib/bunnish/command/count.rb
bunnish-0.0.7	lib/bunnish/command/count.rb
bunnish-0.0.6	lib/bunnish/command/count.rb