Method: Propono::SqsMessage#initialize

Defined in:
lib/propono/components/sqs_message.rb

#initialize(raw_message) ⇒ SqsMessage

Returns a new instance of SqsMessage.



4
5
6
7
8
9
10
11
12
13
 
# File 'lib/propono/components/sqs_message.rb', line 4

def initialize(raw_message)
  raw_body = raw_message.body
  @raw_body_json = JSON.parse(raw_body)
  body = JSON.parse(@raw_body_json["Message"])

  @context        = Propono::Utils.symbolize_keys body
  @failure_count  = context[:num_failures] || 0
  @message        = context.delete(:message)
  @receipt_handle = raw_message.receipt_handle
end