_poll

in lib/aws/active_job/sqs/poller.rb [125:136]

• 11 lines of code
• 2 McCabe index (conditional complexity)

        def _poll(poller_options, queue_url)
          poller = Aws::SQS::QueuePoller.new(
            queue_url,
            client: Aws::ActiveJob::SQS.config.client
          )
          single_message = poller_options[:max_number_of_messages] == 1
          poller.poll(poller_options) do |msgs|
            msgs = [msgs] if single_message
            execute_messages(msgs, queue_url)
          end
        end