Sha256: 8a4650f06baad03710e4f05d13b8a0044d2f708e4b243ca00eb7b974a71c821c

Contents?: true

Size: 496 Bytes

Versions: 1

Compression:

Stored size: 496 Bytes

Contents

module Sidekiq
  module Worker
    module ClassMethods
      def within_sidekiq_retries_exhausted_block user_msg = {}, &block
        block.call
        self.sidekiq_retries_exhausted_block.call default_retries_exhausted_args.merge(user_msg)
      end

      def default_retries_exhausted_args
        {
          'queue' => get_sidekiq_options[:worker],
          'class' => self.name,
          'args' => [],
          'error_message' => 'An error occured'
        }
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
rspec-sidekiq-1.1.0 lib/rspec/sidekiq/helpers/within_sidekiq_retries_exhausted_block.rb