Contents

require 'fileutils'
require 'active_support/core_ext/object'
require 'backgrounder/support/backends'
require 'backgrounder/orm/base'
require 'backgrounder/delay'

module CarrierWave
  module Backgrounder
    include Support::Backends

    class << self
      attr_reader :worker_klass
    end

    def self.configure
      yield self

      case backend
      when :active_job
        @worker_klass = "CarrierWave::Workers::ActiveJob"

        require 'active_job'
        require 'backgrounder/workers/active_job/process_asset'
        require 'backgrounder/workers/active_job/store_asset'

        queue_name = queue_options['queue'] || 'carrierwave'

        ::CarrierWave::Workers::ActiveJob::ProcessAsset.class_eval do
          queue_as queue_name
        end
        ::CarrierWave::Workers::ActiveJob::StoreAsset.class_eval do
          queue_as queue_name
        end
      when :sidekiq
        @worker_klass = "CarrierWave::Workers"

        require 'sidekiq'
        ::CarrierWave::Workers::ProcessAsset.class_eval do
          include ::Sidekiq::Worker
        end
        ::CarrierWave::Workers::StoreAsset.class_eval do
          include ::Sidekiq::Worker
        end
      end
    end
  end
end

require 'backgrounder/railtie' if defined?(Rails)

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
carrierwave_backgrounder-1.0.0	lib/carrierwave_backgrounder.rb
carrierwave_backgrounder-1.0.0.beta.2	lib/carrierwave_backgrounder.rb