Sha256: ed3c882244c0cc55f390feeecf1ba89b1614a061ca21dac2f25b119ad6beb459
Contents?: true
Size: 558 Bytes
Versions: 8
Compression:
Stored size: 558 Bytes
Contents
require 'legion/extensions/transport'
module Legion::Extensions::Node::Transport
extend Legion::Extensions::Transport
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
end
Version data entries
8 entries across 8 versions & 1 rubygems