Sha256: 917eaab84461b1e275c6010b0759dbc19a4a191e3b4b4bfa6acb408a7bef61d8

Contents?: true

Size: 933 Bytes

Versions: 4

Compression:

Stored size: 933 Bytes

Contents

module Sidekiq
  class Client

    ##
    # The Sidekiq inline infrastructure overrides perform_async so that it
    # actually calls perform instead. This allows workers to be run inline in a
    # testing environment.
    #
    # This is similar to `Resque.inline = true` functionality.
    #
    # Example:
    #
    #   require 'sidekiq/testing/inline'
    #
    #   $external_variable = 0
    #
    #   class ExternalWorker
    #     include Sidekiq::Worker
    #
    #     def perform
    #       $external_variable = 1
    #     end
    #   end
    #
    #   assert_equal 0, $external_variable
    #   ExternalWorker.perform_async
    #   assert_equal 1, $external_variable
    #
    singleton_class.class_eval do
      alias_method :raw_push_old, :raw_push
      def raw_push(hash, _)
        hash['class'].constantize.new.perform(*Sidekiq.load_json(Sidekiq.dump_json(hash['args'])))
        true
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
sidekiq-2.5.3 lib/sidekiq/testing/inline.rb
sidekiq-2.5.2 lib/sidekiq/testing/inline.rb
sidekiq-2.5.1 lib/sidekiq/testing/inline.rb
sidekiq-2.5.0 lib/sidekiq/testing/inline.rb