Sha256: d26ce1be1e795c7653d76c1e6822548a037074beb06bb1106ea29c907d615d0e

Contents?: true

Size: 460 Bytes

Versions: 4

Compression:

Stored size: 460 Bytes

Contents

# frozen_string_literal: true

require "active_job" if defined?(Rails)

module Munster
  class ProcessingJob < ActiveJob::Base
    def perform(webhook)
      # TODO: there should be some sort of locking or concurrency control here, but it's outside of
      # Munsters scope of responsibility. Developer implementing this should decide how this should be handled.
      webhook.handler.process(webhook)
      # TODO: remove process attribute
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
munster-0.3.1 lib/munster/jobs/processing_job.rb
munster-0.3.0 lib/munster/jobs/processing_job.rb
munster-0.2.0 lib/munster/jobs/processing_job.rb
munster-0.1.0 lib/munster/jobs/processing_job.rb