Class: RServiceBus2::SubscriptionManager
- Inherits:
-
Object
- Object
- RServiceBus2::SubscriptionManager
- Defined in:
- lib/rservicebus2/subscription_manager.rb
Overview
Subscription Manager
Instance Method Summary collapse
- #add(event_name, queue_name) ⇒ Object
-
#get(event_name) ⇒ Object
Get subscriptions for given eventName.
-
#initialize(subscription_storage) ⇒ SubscriptionManager
constructor
A new instance of SubscriptionManager.
- #remove(_event_name, _queue_name) ⇒ Object
Constructor Details
#initialize(subscription_storage) ⇒ SubscriptionManager
Returns a new instance of SubscriptionManager.
4 5 6 7 |
# File 'lib/rservicebus2/subscription_manager.rb', line 4 def initialize(subscription_storage) @subscription_storage = subscription_storage @subscriptions = @subscription_storage.get_all end |
Instance Method Details
#add(event_name, queue_name) ⇒ Object
21 22 23 24 25 |
# File 'lib/rservicebus2/subscription_manager.rb', line 21 def add(event_name, queue_name) RServiceBus2.log 'Adding subscription for, ' + event_name + ', to, ' + queue_name @subscriptions = @subscription_storage.add(event_name, queue_name) end |
#get(event_name) ⇒ Object
Get subscriptions for given eventName
10 11 12 13 14 15 16 17 18 19 |
# File 'lib/rservicebus2/subscription_manager.rb', line 10 def get(event_name) subscriptions = @subscriptions[event_name] if subscriptions.nil? RServiceBus2.log "No subscribers for event, #{event_name}" RServiceBus2.log "If there should be, ensure you have the appropriate evironment variable set, eg MESSAGE_ENDPOINT_MAPPINGS=#{event_name}:<Queue Name>" return [] end subscriptions end |
#remove(_event_name, _queue_name) ⇒ Object
27 28 29 |
# File 'lib/rservicebus2/subscription_manager.rb', line 27 def remove(_event_name, _queue_name) fail 'Method, remove, needs to be implemented for this subscription storage' end |