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