Sha256: 5cb32bc1fa67393d5e43abbe937af58df69f7fc462e51ad8cf80d1617a5e7ca4

Contents?: true

Size: 1.3 KB

Versions: 53

Compression:

Stored size: 1.3 KB

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.prefetch(1)

# Acknowledgements are good for letting the server know
# that the task is finished. If the consumer doesn't send
# the acknowledgement, then the task is considered to be unfinished
# and will be requeued when consumer closes AMQP connection (because of a crash, for example).
channel.queue("amqpgem.examples.patterns.command", :durable => true, :auto_delete => false).subscribe(:ack => true) do |metadata, payload|
  case metadata.type
  when "gems.install"
    data = YAML.load(payload)
    puts "[gems.install] Received a 'gems.install' request with #{data.inspect}"

    # just to demonstrate a realistic example
    shellout = "gem install #{data[:gem]} --version '#{data[:version]}'"
    puts "[gems.install] Executing #{shellout}"; system(shellout)

    puts
    puts "[gems.install] Done"
    puts
  else
    puts "[commands] Unknown command: #{metadata.type}"
  end

  # message is processed, acknowledge it so that broker discards it
  metadata.ack
end

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

Version data entries

53 entries across 53 versions & 1 rubygems

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