class MessageQueue::Producer
Attributes
connection[R]
options[R]
Public Class Methods
new(connection, options = {})
click to toggle source
# File lib/message_queue/producer.rb, line 10 def initialize(connection, options = {}) @connection = connection @options = deep_clone(options) end
Public Instance Methods
default_options()
click to toggle source
# File lib/message_queue/producer.rb, line 19 def default_options { :content_type => connection.serializer.content_type, :timestamp => Time.now.utc.to_i, :message_id => generate_id } end
dump_object(object)
click to toggle source
# File lib/message_queue/producer.rb, line 15 def dump_object(object) connection.serializer.dump(object) end
Private Instance Methods
generate_id()
click to toggle source
# File lib/message_queue/producer.rb, line 25 def generate_id SecureRandom.uuid end