module Apollo::Agent

Public Class Methods

declare_entities(channel, opts={}) click to toggle source
# File lib/apollo_crawler/agent/exchanges.rb, line 57
def self.declare_entities(channel, opts={})
        exchanges = self.declare_exchanges(channel, opts)
        queues = self.declare_queues(channel, opts)

        # Compose res
        res = {
                :exchanges => exchanges,
                :queues => queues                           
        }

        return res
end
declare_exchanges(channel, opts={}) click to toggle source
# File lib/apollo_crawler/agent/exchanges.rb, line 40
def self.declare_exchanges(channel, opts={})
        if(opts[:verbose])
                puts "Declaring AMQP Exchanges"
        end
        
        # Exchanges
        exchanges = {}
        exchanges["crawler"] = channel.direct("crawler", :auto_delete => false, :durable => true)
        exchanges["domainer"] = channel.direct("domainer", :auto_delete => false, :durable => true)
        exchanges["fetcher"] = channel.direct("fetcher", :auto_delete => false, :durable => true)
        exchanges["planner.crawled"] = channel.direct("planner.crawled", :auto_delete => false, :durable => true)
        exchanges["planner.domained"] = channel.direct("planner.domained", :auto_delete => false, :durable => true)
        exchanges["planner.fetched"] = channel.direct("planner.fetched", :auto_delete => false, :durable => true)
        
        return exchanges
end
declare_queues(channel, opts={}) click to toggle source
# File lib/apollo_crawler/agent/exchanges.rb, line 23
def self.declare_queues(channel, opts={})
        if(opts[:verbose])
                puts "Declaring AMQP Queues"
        end

        # Queues
        queues = {}
        queues["crawler.queue"] = channel.queue("crawler.queue", :auto_delete => false, :durable => true)
        queues["domainer.queue"] = channel.queue("domainer.queue", :auto_delete => false, :durable => true)
        queues["fetcher.queue"] = channel.queue("fetcher.queue", :auto_delete => false, :durable => true)
        queues["planner.crawled.queue"] = channel.queue("planner.crawled.queue", :auto_delete => false, :durable => true)
        queues["planner.domained.queue"] = channel.queue("planner.domained.queue", :auto_delete => false, :durable => true)
        queues["planner.fetched.queue"] = channel.queue("planner.fetched.queue", :auto_delete => false, :durable => true)

        return queues
end