class Announce::Adapters::ShoryukenAdapter::BrokerManager

Public Instance Methods

configure() click to toggle source

actually configure the broker queues, topics, and subscriptions

# File lib/announce/adapters/shoryuken_adapter.rb, line 50
def configure
  if options[:verify_only]
    Announce.logger.warn(
      "Running Announce BrokerManager configure in verify_only mode."
    )
    Announce.logger.warn(
      "Resources will be logged, not created; please verify they exist."
    )
  end
  configure_publishing && configure_subscribing
end
configure_publishing() click to toggle source
# File lib/announce/adapters/shoryuken_adapter.rb, line 62
def configure_publishing
  (options[:publish] || {}).each do |subject, actions|
    Array(actions).each do |action|
      topic = ShoryukenAdapter::Topic.new(subject, action, options)
      options[:verify_only] ? topic.verify : topic.create
    end
  end
  true
end
configure_subscribing() click to toggle source
# File lib/announce/adapters/shoryuken_adapter.rb, line 72
def configure_subscribing
  (options[:subscribe] || {}).each do |subject, actions|
    Array(actions).each do |action|
      topic = ShoryukenAdapter::Topic.new(subject, action, options)
      queue = ShoryukenAdapter::Queue.new(subject, action, options)
      if options[:verify_only]
        topic.verify
        queue.verify
        topic.verify_subscription(queue)
      else
        topic.create
        queue.create
        topic.subscribe(queue)
      end
    end
  end
  true
end