Contents

module EventSourcery
  module EventProcessing
    module ErrorHandlers
      class ConstantRetry
        include EventSourcery::EventProcessing::ErrorHandlers::ErrorHandler
        DEFAULT_RETRY_INVERAL = 1
        def initialize(processor_name:)
          @processor_name = processor_name
          @retry_interval = DEFAULT_RETRY_INVERAL
        end

        def with_error_handling
          yield
        rescue => error
          report_error(error)
          sleep(@retry_interval)

          retry
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
event_sourcery-0.14.0	lib/event_sourcery/event_processing/error_handlers/constant_retry.rb
event_sourcery-0.13.0	lib/event_sourcery/event_processing/error_handlers/constant_retry.rb