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