class Aws::Rails::SqsActiveJob::Executor

def initialize(options = {})
  @executor = Concurrent::ThreadPoolExecutor.new(DEFAULTS.merge(options))
  @logger = options[:logger] || ActiveSupport::Logger.new(STDOUT)
end