Sha256: c0aa439a68444bfb51fcd55bc21f009bd25e3c9ebc921bc89c12041d397bf1da

Contents?: true

Size: 374 Bytes

Versions: 18

Compression:

Stored size: 374 Bytes

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