class Totoro::Config
Public Class Methods
new(prefix = nil)
click to toggle source
# File lib/totoro/config.rb, line 5 def initialize(prefix = nil) @data = Rails.application.config_for(:totoro).with_indifferent_access @data = @data[prefix] if prefix.present? end
Public Instance Methods
clean_start?(id)
click to toggle source
# File lib/totoro/config.rb, line 34 def clean_start?(id) !!@data[:queue][id][:clean_start] end
connect()
click to toggle source
# File lib/totoro/config.rb, line 14 def connect @data[:connect] end
exchange(id)
click to toggle source
# File lib/totoro/config.rb, line 18 def exchange(id) @data[:exchange][id][:name] end
exchange_name_for_queue(queue_id)
click to toggle source
# File lib/totoro/config.rb, line 22 def exchange_name_for_queue(queue_id) @data[:queue][queue_id][:exchange] end
exchange_persistent?(id)
click to toggle source
# File lib/totoro/config.rb, line 30 def exchange_persistent?(id) !!@data[:exchange][id][:persistent] end
force_ack?(id)
click to toggle source
# File lib/totoro/config.rb, line 42 def force_ack?(id) manual_ack?(id) && !!@data[:queue][id][:force_ack] end
manual_ack?(id)
click to toggle source
# File lib/totoro/config.rb, line 38 def manual_ack?(id) !!@data[:queue][id][:manual_ack] end
queue(id)
click to toggle source
# File lib/totoro/config.rb, line 46 def queue(id) name = @data[:queue][id][:name] settings = { durable: @data[:queue][id][:durable] } [name, settings] end
queue_persistent?(id)
click to toggle source
# File lib/totoro/config.rb, line 26 def queue_persistent?(id) !!@data[:queue][id][:persistent] end
reset_data()
click to toggle source
# File lib/totoro/config.rb, line 10 def reset_data @data = nil end