Contents

module Reactor
  module Workers
    class DatabaseSubscriberWorker

      include Sidekiq::Worker

      def perform(model_id, data)
        return :__perform_aborted__ unless should_perform?
        Reactor::Subscriber.fire(model_id, data)
      end

      def should_perform?
        if Reactor.test_mode?
          Reactor.test_mode_subscriber_enabled? Reactor::Subscriber
        else
          true
        end
      end

    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
reactor-0.18.0	lib/reactor/workers/database_subscriber_worker.rb
reactor-0.17.0	lib/reactor/workers/database_subscriber_worker.rb
reactor-0.16.1	lib/reactor/workers/database_subscriber_worker.rb
reactor-0.16.0	lib/reactor/workers/database_subscriber_worker.rb
reactor-0.15.1	lib/reactor/workers/database_subscriber_worker.rb
reactor-0.15.0	lib/reactor/workers/database_subscriber_worker.rb
reactor-0.14.0	lib/reactor/workers/database_subscriber_worker.rb