module AsyncObserver::Extensions
  def async_execute(selector, *args)
    if RAILS_ENV == 'test' # this is due to async_obeserver's poor test integration :(
      self.send selector, *args
    else
      begin
        self.async_send selector, *args
      rescue Beanstalk::UnexpectedResponse, Beanstalk::NotConnected
        # Beanstalk is having an issue, run the command directly
        self.send selector, *args
      end
    end
  end
end