Skip to content

Instantly share code, notes, and snippets.

Avatar

Wilfrido Nuqui Jr. wnuqui

View GitHub Profile
View request_response_client.rb
require "amqp"
EventMachine.run do
connection = AMQP.connect
channel = AMQP::Channel.new(connection)
replies_queue = channel.queue("", :exclusive => true, :auto_delete => true)
replies_queue.subscribe do |metadata, payload|
puts "[response] Response for #{metadata.correlation_id}: #{payload.inspect}"
end
You can’t perform that action at this time.