class MessageDriver::Adapters::InMemoryAdapter::Subscription

Public Instance Methods

deliver_message(message) click to toggle source
# 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() click to toggle source
# File lib/message_driver/adapters/in_memory_adapter.rb, line 16
def unsubscribe
  adapter.remove_subscription_for(destination.name, self)
end