Contents

# frozen_string_literal: true

module Jackhammer
  class TopicManager
    class << self
      def topics
        topics = {}
        Jackhammer.configuration.yaml.each do |topic, topic_config|
          queues = topic_config.delete 'queues'
          topics[topic.to_sym] = Topic.new(name: topic, options: topic_config, queue_config: queues)
        end
        topics
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
jackhammer-0.2.2	lib/jackhammer/topic_manager.rb
jackhammer-0.2.1	lib/jackhammer/topic_manager.rb
jackhammer-0.2.0	lib/jackhammer/topic_manager.rb
jackhammer-0.1.1	lib/jackhammer/topic_manager.rb
jackhammer-0.1.0	lib/jackhammer/topic_manager.rb