publisher.rb

publisher.rb

          def publish(urlSearch, routing_key)
            EM.run do
              
              corr_id = rand(10_000_000).to_s
            
              requests ||= Hash.new
            
              connection = AMQP.connect(:host => "localhost")
              
              callback_queue = AMQP::Channel.new(connection).queue("", :exclusive => true)             
              
              callback_queue.subscribe do |header, body|
                
                reply = MultiJson.decode(body)               
                
                if reply[:is_last.to_s]  
                  connection.close do
                    EM.stop{exit}
                  end
                end
              end                          
              
              callback_queue.append_callback(:declare) do
                AMQP::Exchange.default.publish(MultiJson.encode(urlSearch), :routing_key => routing_key, :reply_to => callback_queue.name, :correlation_id => corr_id)
              end
            
            end