class Aws::Rails::SqsActiveJob::Executor

def shutdown(timeout=nil)
  @executor.shutdown
  clean_shutdown = @executor.wait_for_termination(timeout)
  if clean_shutdown
    @logger.info 'Clean shutdown complete.  All executing jobs finished.'
  else
    @logger.info "Timeout (#{timeout}) exceeded.  Some jobs may not have"\
      " finished cleanly.  Unfinished jobs will not be removed from"\
      " the queue and can be ru-run once their visibility timeout"\
      " passes."
  end
end