lib/pheme/queue_poller.rb in pheme-4.1.0 vs lib/pheme/queue_poller.rb in pheme-4.1.1
- old
+ new
@@ -125,15 +125,19 @@
decompress(body['Message'])
end
def parse_csv(message_contents)
parsed_body = SmarterCSV.process(StringIO.new(message_contents))
+ # rubocop:disable Vendor/RecursiveOpenStructUse
parsed_body.map { |item| RecursiveOpenStruct.new(item, recurse_over_arrays: true) }
+ # rubocop:enable Vendor/RecursiveOpenStructUse
end
def parse_json(message_contents)
parsed_body = JSON.parse(message_contents)
+ # rubocop:disable Vendor/RecursiveOpenStructUse
RecursiveOpenStruct.new({ wrapper: parsed_body }, recurse_over_arrays: true).wrapper
+ # rubocop:enable Vendor/RecursiveOpenStructUse
end
def handle(message, metadata, message_attributes)
if @message_handler
@message_handler.new(message: message, metadata: metadata, message_attributes: message_attributes).handle