class MessageQueue::Adapters::Memory::Connection

Public Instance Methods

new_consumer(options = {}) click to toggle source
# File lib/message_queue/adapters/memory/connection.rb, line 6
def new_consumer(options = {})
  Consumer.new(self, options)
end
new_producer(options = {}) click to toggle source
# File lib/message_queue/adapters/memory/connection.rb, line 2
def new_producer(options = {})
  Producer.new(self, options)
end