Sidekiq Proxy Workers

email_worker_proxy.rb

class EmailWorkerProxy
  include WorkerProxy
  sidekiq_options queue: 'email', retry: false
end

enqueue_from_outside_project.rb

require 'sidekiq'
# set up / connect Sidekiq
Sidekiq::Client.push(
  class: 'EmailWorker',
  queue: 'email',
  retry: false,
  args: ['test@example.org', 'Hello World']
)

enqueue_from_project.rb

EmailWorker.perform_async('test@example.org', 'Hello World')

enqueue_with_proxy.rb

EmailWorkerProxy.perform_async('test@example.org', 'Hello World')

worker.rb

class EmailWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'email', retry: false

  # dequeuing and executing job
  def perform(recipient, message)
    send_email recipient, message
  end

  private
  def send_email(recipient, message)
    # code omitted
  end
end

worker_proxy.rb

module WorkerProxy
  def self.included(base)
    base.send(:include, Sidekiq::Worker)
    base.extend ClassMethods
  end

  module ClassMethods
    # override
    def client_push(item)
      # get sidekiq options defined in proxy
      extended_item = get_sidekiq_options.merge(item)

      # strip 'Proxy' from class name
      proxied_class_name = to_s[0..-6]

      super(extended_item.merge 'class' => proxied_class_name)
    end
  end
end