execute_messages

in lib/aws/active_job/sqs/poller.rb [137:149]

• 12 lines of code
• 1 McCabe index (conditional complexity)

        def execute_messages(msgs, queue_url)
          @logger.info "Processing batch of #{msgs.length} messages"
          msgs.each do |msg|
            sqs_message = Aws::SQS::Message.new(
              queue_url: queue_url,
              receipt_handle: msg.receipt_handle,
              data: msg,
              client: Aws::ActiveJob::SQS.config.client
            )
            @executor.execute(sqs_message)
          end
        end