class MessageDriver::Adapters::InMemoryAdapter::InMemoryContext
Public Instance Methods
handle_consumer_count(destination)
click to toggle source
# File lib/message_driver/adapters/in_memory_adapter.rb, line 132 def handle_consumer_count(destination) adapter.consumer_count_for(destination.name) end
handle_message_count(destination)
click to toggle source
# File lib/message_driver/adapters/in_memory_adapter.rb, line 128 def handle_message_count(destination) destination.handle_message_count end
handle_pop_message(destination, options = {})
click to toggle source
# File lib/message_driver/adapters/in_memory_adapter.rb, line 120 def handle_pop_message(destination, options = {}) destination.handle_pop_message(self, options) end
handle_publish(destination, body, headers = {}, properties = {})
click to toggle source
# File lib/message_driver/adapters/in_memory_adapter.rb, line 116 def handle_publish(destination, body, headers = {}, properties = {}) destination.handle_publish(body, headers, properties) end
handle_subscribe(destination, options = {}, &consumer)
click to toggle source
# File lib/message_driver/adapters/in_memory_adapter.rb, line 124 def handle_subscribe(destination, options = {}, &consumer) destination.handle_subscribe(options, &consumer) end
supports_subscriptions?()
click to toggle source
# File lib/message_driver/adapters/in_memory_adapter.rb, line 136 def supports_subscriptions? true end