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 53
def configure
  configure_publishing && configure_subscribing
end
configure_publishing() click to toggle source
# File lib/announce/adapters/shoryuken_adapter.rb, line 57
def configure_publishing
  (options[:publish] || {}).each do |subject, actions|
    Array(actions).each do |action|
      ShoryukenAdapter::Topic.new(subject, action, options).create
    end
  end
  true
end
configure_subscribing() click to toggle source
# File lib/announce/adapters/shoryuken_adapter.rb, line 66
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)
      topic.create
      queue.create
      topic.subscribe(queue)
    end
  end
  true
end