Class: MessageDriver::Adapters::InMemoryAdapter::Subscription

Inherits:
Subscription::Base show all
Defined in:
lib/message_driver/adapters/in_memory_adapter.rb

Instance Attribute Summary

Attributes inherited from Subscription::Base

#adapter, #consumer, #destination, #options

Instance Method Summary collapse

Methods inherited from Subscription::Base

#initialize

Constructor Details

This class inherits a constructor from MessageDriver::Subscription::Base

Instance Method Details

#deliver_message(message) ⇒ Object 



20
21
22
23
24
25
26
 
# File 'lib/message_driver/adapters/in_memory_adapter.rb', line 20

def deliver_message(message)
  consumer.call(message)
rescue => e
  unless options[:error_handler].nil?
    options[:error_handler].call(e, message)
  end
end

#unsubscribe ⇒ Object 



16
17
18
 
# File 'lib/message_driver/adapters/in_memory_adapter.rb', line 16

def unsubscribe
  adapter.remove_subscription_for(destination.name, self)
end