Module: Legion::Extensions::Node::Transport

Extended by:
Transport
Defined in:
lib/legion/extensions/node/transport.rb,
lib/legion/extensions/node/transport/exchanges/node.rb

Defined Under Namespace

Modules: Exchanges, Messages, Queues

Class Method Summary collapse

Class Method Details

.additional_e_to_q ⇒ Object 



5
6
7
8
9
10
11
 
# File 'lib/legion/extensions/node/transport.rb', line 5

def self.additional_e_to_q
  array = [{ from: 'node', to: 'node', routing_key: "node.#{Legion::Settings[:client][:name]}" }]
  array.push(from: 'node', to: 'node', routing_key: 'node.data.#') if Legion::Settings[:data][:connected]
  array.push(from: 'node', to: 'node', routing_key: 'node.cache.#') if Legion::Settings[:cache][:connected]
  array.push(from: 'node', to: 'node', routing_key: 'node.crypt.#')
  array
end