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