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