Class: DispatchRider::QueueServices::AwsSqs::MessageBodyExtractor

Inherits:
Object
  • Object
show all
Defined in:
lib/dispatch-rider/queue_services/aws_sqs/message_body_extractor.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(raw_message) ⇒ MessageBodyExtractor

Returns a new instance of MessageBodyExtractor.



7
8
9
 
# File 'lib/dispatch-rider/queue_services/aws_sqs/message_body_extractor.rb', line 7

def initialize(raw_message)
  @parsed_message = JSON.parse(raw_message.body)
end

Instance Attribute Details

#parsed_message ⇒ Object (readonly)

Returns the value of attribute parsed_message.



5
6
7
 
# File 'lib/dispatch-rider/queue_services/aws_sqs/message_body_extractor.rb', line 5

def parsed_message
  @parsed_message
end

Instance Method Details

#extract ⇒ Object 



11
12
13
 
# File 'lib/dispatch-rider/queue_services/aws_sqs/message_body_extractor.rb', line 11

def extract
  parsed_message.has_key?("Message") ? parsed_message["Message"] : parsed_message.to_json
end