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

Extended by:
Transport
Defined in:
lib/legion/extensions/node/transport.rb,
lib/legion/extensions/node/transport/queues/node.rb,
lib/legion/extensions/node/transport/queues/crypt.rb,
lib/legion/extensions/node/transport/queues/vault.rb,
lib/legion/extensions/node/transport/messages/beat.rb,
lib/legion/extensions/node/transport/queues/health.rb,
lib/legion/extensions/node/transport/exchanges/node.rb,
lib/legion/extensions/node/transport/messages/public_key.rb,
lib/legion/extensions/node/transport/messages/update_result.rb,
lib/legion/extensions/node/transport/queues/cluster_control.rb,
lib/legion/extensions/node/transport/exchanges/cluster_control.rb,
lib/legion/extensions/node/transport/messages/cluster_settings.rb,
lib/legion/extensions/node/transport/messages/push_vault_token.rb,
lib/legion/extensions/node/transport/messages/cluster_killswitch.rb,
lib/legion/extensions/node/transport/messages/push_cluster_secret.rb,
lib/legion/extensions/node/transport/messages/request_public_keys.rb,
lib/legion/extensions/node/transport/messages/request_vault_token.rb,
lib/legion/extensions/node/transport/messages/request_cluster_secret.rb

Defined Under Namespace

Modules: Exchanges, Messages, Queues

Class Method Summary collapse

Class Method Details

.additional_e_to_q ⇒ Object 



11
12
13
14
15
16
17
18
 
# File 'lib/legion/extensions/node/transport.rb', line 11

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) || false
  array.push(from: 'node', to: 'node', routing_key: 'node.cache.#') if Legion::Settings[:cache]&.[](:connected) || false
  array.push(from: 'node', to: 'node', routing_key: 'node.crypt.#')
  array.push(from: 'cluster_control', to: 'cluster_control', routing_key: '#')
  array
end