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