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