Class: Announce::Adapters::ShoryukenAdapter::BrokerManager

Inherits:
BaseAdapter::BrokerManager show all
Defined in:
lib/announce/adapters/shoryuken_adapter.rb

Instance Attribute Summary

Attributes inherited from BaseAdapter::BrokerManager

#options

Instance Method Summary collapse

Methods inherited from BaseAdapter::BrokerManager

#initialize

Constructor Details

This class inherits a constructor from Announce::Adapters::BaseAdapter::BrokerManager

Instance Method Details

#configure ⇒ Object

actually configure the broker queues, topics, and subscriptions



53
54
55
 
# File 'lib/announce/adapters/shoryuken_adapter.rb', line 53

def configure
  configure_publishing && configure_subscribing
end

#configure_publishing ⇒ Object 



57
58
59
60
61
62
63
64
 
# 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 ⇒ Object 



66
67
68
69
70
71
72
73
74
75
76
77
 
# 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