Sha256: 0c3dd488460adc95628b59ddaf9b1cb9931b204d10e47907709b4d38fe1d683b
Contents?: true
Size: 483 Bytes
Versions: 53
Compression:
Stored size: 483 Bytes
Contents
#!/usr/bin/env ruby
# encoding: utf-8
if defined?(Bundler)
Bundler.setup
else
require "rubygems"
end
require "amqp"
puts "Running amqp gem #{AMQP::VERSION}"
AMQP.start(:host => '127.0.0.1') do |connection|
channel = AMQP::Channel.new(connection)
exchange = channel.direct("")
queue = channel.queue("indexer_queue", { :durable => true })
EM.add_periodic_timer(1) {
queue.status do |num_messages, num_consumers|
puts "msgs:#{num_messages}"
end
}
end
Version data entries
53 entries across 53 versions & 1 rubygems