class Jackhammer::TopicManager

Public Class Methods

topics() click to toggle source
# File lib/jackhammer/topic_manager.rb, line 4
def topics
  result = {}
  Jackhammer.configuration.yaml.each do |topic, topic_config|
    fail(InvalidConfigError, "Topic config is invalid") unless topic_config.is_a?(Hash)
    queues = topic_config.delete 'queues'
    result[topic.to_sym] = Topic.new(name: topic, options: topic_config, queue_config: queues)
  end
  result
end