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