poller_options

in lib/aws/active_job/sqs/poller.rb [107:124]

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

        def poller_options(queue)
          config = Aws::ActiveJob::SQS.config
          queue_url = config.url_for(queue)
          poller_options = {
            skip_delete: true,
            max_number_of_messages: config.max_messages_for(queue),
            visibility_timeout: config.visibility_timeout_for(queue)
          }

          
          
          
          
          
          poller_options[:max_number_of_messages] = 1 if Aws::ActiveJob::SQS.fifo?(queue_url)
          poller_options
        end