Module: Smith::QueueDefinitions

Defined in:
lib/smith/queue_definitions.rb

Constant Summary collapse

Agent_keepalive =
QueueDefinition.new("#{Smith.hostname}.agent.keepalive", :auto_delete => false, :durable => true)
Agent_lifecycle =
QueueDefinition.new("#{Smith.hostname}.agent.lifecycle", :auto_delete => false, :durable => true)
Agent_stats =
QueueDefinition.new('agent.stats', :durable => true, :auto_delete => true)
Agent_control =

Something tells me that I’ve crossed line with this.

->(uuid) { QueueDefinition.new("agent.control.#{uuid}", :durable => false, :auto_delete => true) }
Agency_control =
->(node=nil) {
  QueueDefinition.new("#{node || Smith.hostname}.agency.control", :auto_ack => false, :durable => true, :persistent => false, :strict => true)
}