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