Class: MessageQueue::Adapters::Memory::Connection

Inherits:
Connection
  • Object
show all
Defined in:
lib/message_queue/adapters/memory/connection.rb

Defined Under Namespace

Classes: Consumer, Producer

Instance Attribute Summary

Attributes inherited from Connection

#serializer, #settings

Instance Method Summary collapse

Methods inherited from Connection

#connect, #connected?, #disconnect, #initialize, #with_connection

Methods included from Logging

#logger, logger, logger=, setup_logger

Constructor Details

This class inherits a constructor from MessageQueue::Connection

Instance Method Details

#new_consumer(options = {}) ⇒ Object



6
7
8
# File 'lib/message_queue/adapters/memory/connection.rb', line 6

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

#new_producer(options = {}) ⇒ Object



2
3
4
# File 'lib/message_queue/adapters/memory/connection.rb', line 2

def new_producer(options = {})
  Producer.new(self, options)
end