Class: Apollo::Agent::DomainerAgent

Inherits:
BaseAgent
  • Object
show all
Defined in:
lib/apollo_crawler/agent/domainer_agent.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from BaseAgent

#run

Constructor Details

#initialize(amqp, opts = {}) ⇒ DomainerAgent

Returns a new instance of DomainerAgent.



33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/apollo_crawler/agent/domainer_agent.rb', line 33

def initialize(amqp, opts={})
	if(opts[:verbose])
		puts "Initializing crawler agent..."
	end

	# Declarations
	channel = amqp.create_channel
	declarations = Apollo::Agent.declare_entities(channel, opts)

	# Binding
	declarations[:queues]["domainer.queue"].bind(declarations[:exchanges]["domainer"]).subscribe do |delivery_info, metadata, payload|
		puts "DomainerAgent: Received, metadata #{metadata.inspect}" if opts[:verbose]

		msg = JSON.parse(payload)
	end
end

Instance Attribute Details

#declarations ⇒ Object

Returns the value of attribute declarations.



31
32
33
 
# File 'lib/apollo_crawler/agent/domainer_agent.rb', line 31

def declarations
  @declarations
end