class Emque::Consuming::Control::Errors

Constants

COMMANDS

Public Instance Methods

clear() click to toggle source
# File lib/emque/consuming/control/errors.rb, line 9
def clear
  app.error_tracker.occurrences.clear
end
down() click to toggle source
# File lib/emque/consuming/control/errors.rb, line 13
def down
  if app.error_tracker.limit > 1
    config.error_limit = app.error_tracker.limit -= 1
    app.verify_error_status
  end
end
expire_after(seconds) click to toggle source
# File lib/emque/consuming/control/errors.rb, line 20
def expire_after(seconds)
  unless seconds.is_a?(Integer)
    raise ArgumentError, "first argument must be an integer"
  end
  config.error_expiration = app.error_tracker.expiration = seconds
end
respond_to?(method) click to toggle source
# File lib/emque/consuming/control/errors.rb, line 35
def respond_to?(method)
  COMMANDS.include?(method.to_sym)
end
retry() click to toggle source
# File lib/emque/consuming/control/errors.rb, line 31
def retry
  app.manager.retry_errors
end
up() click to toggle source
# File lib/emque/consuming/control/errors.rb, line 27
def up
  config.error_limit = app.error_tracker.limit += 1
end