Sha256: 583cda4fb5ead2c2deea1978b6c63bd3823fdf2ffe8e3ef05b90c4be23c4b842

Contents?: true

Size: 566 Bytes

Versions: 4

Compression:

Stored size: 566 Bytes

Contents

module Lambdakiq
  module Worker
    extend ActiveSupport::Concern

    included do
      class_attribute :lambdakiq_options_hash,
                      instance_predicate: false,
                      default: Hash.new
    end

    class_methods do

      def lambdakiq_options(options = {})
        self.lambdakiq_options_hash = options.symbolize_keys
      end

    end

    def lambdakiq?
      true
    end

    def lambdakiq_retry
      lambdakiq_options_hash[:retry]
    end

    def lambdakiq_async?
      !!lambdakiq_options_hash[:async]
    end

  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
lambdakiq-2.0.0 lib/lambdakiq/worker.rb
lambdakiq-1.0.4 lib/lambdakiq/worker.rb
lambdakiq-1.0.3 lib/lambdakiq/worker.rb
lambdakiq-1.0.2 lib/lambdakiq/worker.rb