Sha256: 8cc079dc1de5f7ac45c34057622f4ad7f0da37fc86d6894f3c7959e598e90f63

Contents?: true

Size: 592 Bytes

Versions: 24

Compression:

Stored size: 592 Bytes

Contents

# frozen_string_literal: true

require "sidekiq_publisher"
require "sidekiq/testing"

module SidekiqPublisher
  module Testing
    def self.prepended(base)
      base.singleton_class.public_send(:alias_method, :original_create_job!, :create_job!)
      base.singleton_class.prepend(ClassMethods)
    end

    module ClassMethods
      def create_job!(item)
        if Sidekiq::Testing.enabled?
          item["class"].sidekiq_client_push(item)
        else
          original_create_job!(item)
        end
      end
    end
  end
end

SidekiqPublisher::Job.prepend(SidekiqPublisher::Testing)

Version data entries

24 entries across 24 versions & 1 rubygems

Version Path
sidekiq_publisher-6.0.0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-5.0.0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-4.0.0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-3.0.0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-2.4.0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-2.3.0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-2.2.0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-2.1.1 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-2.1.0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-2.0.1 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-2.0.0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-2.0.0.rc0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-1.8.0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-1.8.0.rc0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-1.7.1 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-1.7.0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-1.7.0.rc1 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-1.7.0.rc0 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-1.6.4 lib/sidekiq_publisher/testing.rb
sidekiq_publisher-1.6.3 lib/sidekiq_publisher/testing.rb