module Services::RabbitWrapper::BaseHelpers
Public Instance Methods
basic_config_params(connection_string, exchange_name)
click to toggle source
# File lib/services/rabbit_wrapper/base_helpers.rb, line 7 def basic_config_params(connection_string, exchange_name) { 'rabbit_mq' => { 'connection_string' => connection_string, 'queue_names' => [ { 'exchange_name' => exchange_name, 'durable' => true } ], 'is_basic' => true } } end
pub_queue_name(queue_name = nil)
click to toggle source
# File lib/services/rabbit_wrapper/base_helpers.rb, line 41 def pub_queue_name(queue_name = nil) return queue_name if @is_basic && !queue_name.nil? return 'queue_name.not.provided' if @is_basic && queue_name.nil? @config.pub_queue_name end
setup_config(connection_string, exchange_name, config)
click to toggle source
# File lib/services/rabbit_wrapper/base_helpers.rb, line 22 def setup_config(connection_string, exchange_name, config) if connection_string && exchange_name @is_basic = true @config = Services::Config::ConfigStruct.new(basic_config_params(connection_string, exchange_name)) else @is_basic = false config.load_config @config = config.config_structs end end
sub_queue_name(queue_name = nil)
click to toggle source
# File lib/services/rabbit_wrapper/base_helpers.rb, line 33 def sub_queue_name(queue_name = nil) return queue_name if @is_basic && !queue_name.nil? return 'queue_name.not.provided' if @is_basic && queue_name.nil? @config.sub_queue_name end