class MessageQueue::Consumer

Attributes

connection[R]
options[R]

Public Class Methods

new(connection, options = {}) click to toggle source
# File lib/message_queue/consumer.rb, line 9
def initialize(connection, options = {})
  @connection = connection
  @options = deep_clone(options)
end

Public Instance Methods

load_object(object) click to toggle source
# File lib/message_queue/consumer.rb, line 14
def load_object(object)
  connection.serializer.load(object)
end