lib/pheme/queue_poller.rb in pheme-3.3.2 vs lib/pheme/queue_poller.rb in pheme-3.3.3

@@ -100,10 +100,10 @@
       parsed_content
     end
 
     def parse_metadata(queue_message)
       message_body = JSON.parse(queue_message.body)
-      { timestamp: message_body['Timestamp'] }
+      { timestamp: message_body['Timestamp'], topic_arn: message_body['TopicArn'] }
     end
 
     def get_metadata(message_body)
       message_body.except('Message', 'Records')
     end