to_queue_url

in lib/aws/active_job/sqs/lambda_handler.rb [58:66]


          def to_queue_url(record)
            source_arn = record['eventSourceARN']
            raise ArgumentError, "Invalid queue arn: #{source_arn}" unless Aws::ARNParser.arn?(source_arn)

            arn = Aws::ARNParser.parse(source_arn)
            sfx = Aws::Partitions::EndpointProvider.dns_suffix_for(arn.region)
            "https://sqs.#{arn.region}.#{sfx}/#{arn.account_id}/#{arn.resource}"
          end