Contents

class MessageQueue::Adapters::Memory::Connection < MessageQueue::Connection
  def new_producer(options = {})
    Producer.new(self, options)
  end

  def new_consumer(options = {})
    Consumer.new(self, options)
  end
end

require "message_queue/adapters/memory/producer"
require "message_queue/adapters/memory/consumer"

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
message_queue-0.1.1	lib/message_queue/adapters/memory/connection.rb
message_queue-0.1.0	lib/message_queue/adapters/memory/connection.rb