class LaGear::Bus::NamespaceUtility
Public Class Methods
add_suffix(routing_key, suffix)
click to toggle source
# File lib/la_gear/bus.rb, line 69 def add_suffix(routing_key, suffix) return "#{routing_key}.#{suffix}" if suffix.present? routing_key end
add_version(routing_key, version)
click to toggle source
# File lib/la_gear/bus.rb, line 64 def add_version(routing_key, version) return add_suffix(routing_key, "v#{version}") if version.present? routing_key end
adjust_routing_key(routing_key, opts = {})
click to toggle source
# File lib/la_gear/bus.rb, line 54 def adjust_routing_key(routing_key, opts = {}) if opts.key?(:version) routing_key = add_version(routing_key, opts[:version]) elsif opts.key?(:suffix) routing_key = add_suffix(routing_key, opts[:suffix]) end routing_key end
local_worker(routing_key)
click to toggle source
# File lib/la_gear/bus.rb, line 50 def local_worker(routing_key) routing_key.split('.').map(&:classify).join('::').constantize end