Class: MessageQueue::Producer

Inherits:

Object

• Object
• MessageQueue::Producer

Includes:

OptionsHelper

Defined in:

lib/message_queue/producer.rb

Direct Known Subclasses

Adapters::Bunny::Connection::Producer, Adapters::Memory::Connection::Producer

Instance Attribute Summary

• #connection ⇒ Object readonly

  Returns the value of attribute connection.

• #options ⇒ Object readonly

  Returns the value of attribute options.

Instance Method Summary

• #default_options ⇒ Object
• #dump_object(object) ⇒ Object
• #initialize(connection, options = {}) ⇒ Producer constructor

  A new instance of Producer.

Methods included from OptionsHelper

#compute_values, #deep_clone

Constructor Details

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

Returns a new instance of Producer.

# File 'lib/message_queue/producer.rb', line 10

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/producer.rb', line 8

def connection
  @connection
end

#options ⇒ Object (readonly)

Returns the value of attribute options.

# File 'lib/message_queue/producer.rb', line 8

def options
  @options
end

Instance Method Details

#default_options ⇒ Object

# 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) ⇒ Object

# File 'lib/message_queue/producer.rb', line 15

def dump_object(object)
  connection.serializer.dump(object)
end