Class: MessageQueue::Consumer

Inherits:

Object

• Object
• MessageQueue::Consumer

Includes:

OptionsHelper

Defined in:

lib/message_queue/consumer.rb

Direct Known Subclasses

Adapters::Bunny::Connection::Consumer, Adapters::Memory::Connection::Consumer

Instance Attribute Summary

• #connection ⇒ Object readonly

  Returns the value of attribute connection.

• #options ⇒ Object readonly

  Returns the value of attribute options.

Instance Method Summary

• #initialize(connection, options = {}) ⇒ Consumer constructor

  A new instance of Consumer.

• #load_object(object) ⇒ Object

Methods included from OptionsHelper

#compute_values, #deep_clone

Constructor Details

#initialize(connection, options = {}) ⇒ Consumer

Returns a new instance of Consumer.

# File 'lib/message_queue/consumer.rb', line 9

def initialize(connection, options = {})
  @connection = connection
  @options = deep_clone(options)
end

Instance Attribute Details

#connection ⇒ Object (readonly)

Returns the value of attribute connection.

# File 'lib/message_queue/consumer.rb', line 7

def connection
  @connection
end

#options ⇒ Object (readonly)

Returns the value of attribute options.

# File 'lib/message_queue/consumer.rb', line 7

def options
  @options
end

Instance Method Details

#load_object(object) ⇒ Object

# File 'lib/message_queue/consumer.rb', line 14

def load_object(object)
  connection.serializer.load(object)
end