Contents

module EventSourcery
  module EventProcessing
    module ErrorHandlers
      module ErrorHandler
        def with_error_handling
          raise NotImplementedError, 'Please implement #with_error_handling method'
        end
        
        private

        def report_error(error)
          error = error.cause if error.instance_of?(EventSourcery::EventProcessingError)
          EventSourcery.logger.error("Processor #{@processor_name} died with #{error}.\n#{error.backtrace.join("\n")}")

          EventSourcery.config.on_event_processor_error.call(error, @processor_name)
        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/error_handler.rb
event_sourcery-0.13.0	lib/event_sourcery/event_processing/error_handlers/error_handler.rb