# File lib/amqp/deprecated/rpc.rb, line 99 def initialize(channel, server_queue_name) @channel = channel @exchange = AMQP::Exchange.default(@channel) @server_queue_name = server_queue_name @handlers = Hash.new @queue = channel.queue("__amqp_gem_rpc_client_#{rand(1_000_000)}", :auto_delete => true) @queue.subscribe do |header, payload| *response_args = Marshal.load(payload) handler = @handlers[header.message_id] handler.call(*response_args) end end