Method: Pheme::QueuePoller#parse_metadata

Defined in:
lib/pheme/queue_poller.rb

#parse_metadata(queue_message) ⇒ Object 



105
106
107
108
 
# File 'lib/pheme/queue_poller.rb', line 105

def parse_metadata(queue_message)
  message_body = JSON.parse(queue_message.body)
  { timestamp: message_body['Timestamp'], topic_arn: message_body['TopicArn'] }
end