Contents

# frozen_string_literal: true
module Apress
  module Api
    class DelayedFireCallback
      include Interactor

      delegate :event, :params, to: :context
      def call
        services = Apress::Api::Callbacks::Config.services(event)

        return if services.blank?

        ::Resque.redis.multi do
          services.each do |service|
            ::Resque.enqueue(
              ::Apress::Api::FireCallbackJob,
              service,
              event,
              params
            )
          end
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
apress-api-1.24.2	app/interactors/apress/api/delayed_fire_callback.rb