Contents

# frozen_string_literal: true

module Eventsimple
  class Reactor < ActiveJob::Base # rubocop:disable Rails/ApplicationJob
    queue_as :eventsimple

    discard_on ActiveJob::DeserializationError do |job, error|
      Rails.logger.warn("Event #{job.arguments.first} not found for reactor: #{self.class}")
    end

    def perform(event)
      call(event)
    end
  end
end

Version data entries

18 entries across 18 versions & 1 rubygems

Version	Path
eventsimple-1.5.6	lib/eventsimple/reactor.rb
eventsimple-1.5.5	lib/eventsimple/reactor.rb
eventsimple-1.5.4	lib/eventsimple/reactor.rb
eventsimple-1.5.3	lib/eventsimple/reactor.rb
eventsimple-1.4.3	lib/eventsimple/reactor.rb
eventsimple-1.4.2	lib/eventsimple/reactor.rb
eventsimple-1.4.1	lib/eventsimple/reactor.rb
eventsimple-1.4.0	lib/eventsimple/reactor.rb
eventsimple-1.3.3	lib/eventsimple/reactor.rb
eventsimple-1.3.2	lib/eventsimple/reactor.rb
eventsimple-1.3.1	lib/eventsimple/reactor.rb
eventsimple-1.3.0	lib/eventsimple/reactor.rb
eventsimple-1.2.3	lib/eventsimple/reactor.rb
eventsimple-1.2.2	lib/eventsimple/reactor.rb
eventsimple-1.2.1	lib/eventsimple/reactor.rb
eventsimple-1.2.0	lib/eventsimple/reactor.rb
eventsimple-1.1.3	lib/eventsimple/reactor.rb
eventsimple-1.1.2	lib/eventsimple/reactor.rb