Class: Legion::Extensions::Node::Transport::Queues::ClusterControl

Inherits:
Transport::Queue
  • Object
show all
Defined in:
lib/legion/extensions/node/transport/queues/cluster_control.rb

Instance Method Summary collapse

Instance Method Details

#queue_name ⇒ Object 



11
12
13
 
# File 'lib/legion/extensions/node/transport/queues/cluster_control.rb', line 11

def queue_name
  "legion.cluster.control.#{Legion::Settings[:client][:name]}"
end

#queue_options ⇒ Object 



15
16
17
18
19
20
21
 
# File 'lib/legion/extensions/node/transport/queues/cluster_control.rb', line 15

def queue_options
  options = Legion::Extensions::Node::Config.control_queue
  { durable:     truthy?(options[:durable], default: true),
    exclusive:   truthy?(options[:exclusive], default: false),
    auto_delete: truthy?(options[:auto_delete], default: false),
    arguments:   queue_arguments(options) }
end