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