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