Contents

# encoding: utf-8

$LOAD_PATH.unshift File.expand_path("../../../../lib", __FILE__)

require "amqp"
require "yaml"

t = Thread.new { EventMachine.run }
sleep(0.5)


connection = AMQP.connect
channel    = AMQP::Channel.new(connection, :auto_recovery => true)
channel.on_error do |ch, channel_close|
  raise "Channel-level exception: #{channel_close.reply_text}"
end

channel.prefetch(1)

channel.queue("", :durable => false, :auto_delete => true).bind("amqpgem.patterns.events").subscribe do |metadata, payload|
  begin
    body = YAML.load(payload)

    case metadata.type
    when "widgets.created"   then
      puts "A widget #{body[:id]} was created"
    when "widgets.destroyed" then
      puts "A widget #{body[:id]} was destroyed"
    when "files.created"     then
      puts "A new file (#{body[:filename]}, #{body[:sha1]}) was uploaded"
    when "files.indexed"     then
      puts "A new file (#{body[:filename]}, #{body[:sha1]}) was indexed"
    else
      puts "[warn] Do not know how to handle event of type #{metadata.type}"
    end
  rescue Exception => e
    puts "[error] Could not handle event of type #{metadata.type}: #{e.inspect}"
  end
end

puts "[boot] Ready"
Signal.trap("INT") { connection.close { EventMachine.stop } }
t.join

Version data entries

46 entries across 46 versions & 1 rubygems

Version	Path
amqp-1.8.0	examples/patterns/event/consumer.rb
amqp-1.7.0	examples/patterns/event/consumer.rb
amqp-1.6.0	examples/patterns/event/consumer.rb
amqp-1.5.3	examples/patterns/event/consumer.rb
amqp-1.5.2	examples/patterns/event/consumer.rb
amqp-1.5.1	examples/patterns/event/consumer.rb
amqp-1.5.0	examples/patterns/event/consumer.rb
amqp-1.4.2	examples/patterns/event/consumer.rb
amqp-1.4.1	examples/patterns/event/consumer.rb
amqp-1.4.0	examples/patterns/event/consumer.rb
amqp-1.3.0	examples/patterns/event/consumer.rb
amqp-1.2.1	examples/patterns/event/consumer.rb
amqp-1.2.0	examples/patterns/event/consumer.rb
amqp-1.1.8	examples/patterns/event/consumer.rb
amqp-1.1.7	examples/patterns/event/consumer.rb
amqp-1.1.6	examples/patterns/event/consumer.rb
amqp-1.1.5	examples/patterns/event/consumer.rb
amqp-1.1.4	examples/patterns/event/consumer.rb
amqp-1.1.3	examples/patterns/event/consumer.rb
amqp-1.0.4	examples/patterns/event/consumer.rb