Port [Python] example for Chapter 1 to Ruby

ruby/.gitignore

@@ -0,0 +1,5 @@
+*~
+*#
+*.class
+*.rbc
+Gemfile.lock

ruby/Gemfile

@@ -0,0 +1,3 @@
+source :rubygems
+
+gem "amqp", "~> 0.8.0.RC12"

ruby/chapter-1/hello_world_consumer.rb

@@ -0,0 +1,21 @@
+if defined?(Bundler); Bundler.setup; else; require "rubygems"; end
+
+require "amqp"
+
+EventMachine.run do
+  AMQP.connect(:host => "localhost", :username => "guest", :password => "guest") do |connection|
+    puts "Connected. Waiting for messages... Hit Control + C to stop me."
+
+    channel  = AMQP::Channel.new(connection)
+    exchange = channel.direct("hello-exchange", :durable => true, :auto_delete => false)
+    channel.queue("hello-queue", :durable => true, :auto_delete => false).bind(exchange, :routing_key => "hola").subscribe do |header, body|
+      puts "Received #{body}"
+
+      connection.close { EventMachine.stop }
+    end
+
+    # stop on Control + c or after 1 second
+    stop = Proc.new { connection.close { EventMachine.stop } }
+    Signal.trap("INT", &stop)
+  end
+end

ruby/chapter-1/hello_world_producer.rb

@@ -0,0 +1,18 @@
+if defined?(Bundler); Bundler.setup; else; require "rubygems"; end
+
+require "amqp"
+
+EventMachine.run do
+  AMQP.connect(:host => "localhost", :username => "guest", :password => "guest") do |connection|
+    puts "Connected. Hit Control + C to stop me."
+
+    channel  = AMQP::Channel.new(connection)
+    channel.direct("hello-exchange", :durable => true, :auto_delete => false).
+      publish(ARGV[0], :routing_key => "hola")
+
+    # stop on Control + c or after 1 second
+    stop = Proc.new { connection.close { EventMachine.stop } }
+    Signal.trap("INT", &stop)
+    EventMachine.add_timer(1, &stop)
+  end
+end