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