#!/usr/bin/env ruby | |
# encoding: utf-8 | |
require "rubygems" | |
require "amqp" | |
EventMachine.run do | |
connection = AMQP.connect(:host => '127.0.0.1') | |
puts "Connected to AMQP broker. Running #{AMQP::VERSION} version of the gem..." | |
channel = AMQP::Channel.new(connection) | |
queue = channel.queue("amqpgem.examples.helloworld", :auto_delete => true) | |
exchange = channel.direct("") | |
queue.subscribe do |payload| | |
puts "Received a message: #{payload}. Disconnecting..." | |
connection.close { EventMachine.stop } | |
end | |
exchange.publish "Hello, world!", :routing_key => queue.name | |
end |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment