Contents

module ActiveJob
  module QueueAdapters
    class LambdaPunchAdapter

      def enqueue(job, options = {})
        job_data = job.serialize
        LambdaPunch.push { ActiveJob::Base.execute(job_data) }
      end

      def enqueue_at(job, timestamp)
        enqueue(job)
      end

    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
lambda_punch-1.1.4	lib/lambda_punch/rails/active_job.rb
lambda_punch-1.1.3	lib/lambda_punch/rails/active_job.rb
lambda_punch-1.1.2	lib/lambda_punch/rails/active_job.rb
lambda_punch-1.1.1	lib/lambda_punch/rails/active_job.rb
lambda_punch-1.1.0	lib/lambda_punch/rails/active_job.rb
lambda_punch-1.0.3	lib/lambda_punch/rails/active_job.rb
lambda_punch-1.0.2	lib/lambda_punch/rails/active_job.rb
lambda_punch-1.0.1	lib/lambda_punch/rails/active_job.rb
lambda_punch-1.0.0	lib/lambda_punch/rails/active_job.rb