Class: Lambdakiq::Message

Inherits:
Object
  • Object
show all
Defined in:
lib/lambdakiq/message.rb

Constant Summary collapse

LAMBDAKIQ_ATTRIBUTE = 
{ 'lambdakiq' => { string_value: '1', data_type: 'String' } }.freeze

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(queue, job, options = {}) ⇒ Message

Returns a new instance of Message.



7
8
9
10
11
 
# File 'lib/lambdakiq/message.rb', line 7

def initialize(queue, job, options = {})
  @queue = queue
  @job = job
  @options = options
end

Instance Attribute Details

#job ⇒ Object (readonly)

Returns the value of attribute job.



5
6
7
 
# File 'lib/lambdakiq/message.rb', line 5

def job
  @job
end

#options ⇒ Object (readonly)

Returns the value of attribute options.



5
6
7
 
# File 'lib/lambdakiq/message.rb', line 5

def options
  @options
end

#queue ⇒ Object (readonly)

Returns the value of attribute queue.



5
6
7
 
# File 'lib/lambdakiq/message.rb', line 5

def queue
  @queue
end

Instance Method Details

#params ⇒ Object 



13
14
15
 
# File 'lib/lambdakiq/message.rb', line 13

def params
  message_params.merge(message_options)
end