Sha256: 146b6e39c3e09a125b96ac929fb9ef943f0c6a0f5d62b46e571c0cf209ca61cb

Contents?: true

Size: 1.49 KB

Versions: 6

Compression:

Stored size: 1.49 KB

Contents

require 'socket'
require 'active_support/all'
require 'active_record'
require 'concurrent'

require 'workhorse/enqueuer'

module Workhorse
  # Check if the available Arel version is greater or equal than 7.0.0
  AREL_GTE_7 = Gem::Version.new(Arel::VERSION) >= Gem::Version.new('7.0.0')

  extend Workhorse::Enqueuer

  @set_up = false

  # Returns the performer currently performing the active job. This can only be
  # called from within a job and the same thread.
  def self.performer
    Thread.current[:workhorse_current_performer]\
      || fail('No performer is associated with the current thread. This method must always be called inside of a job.')
  end

  mattr_accessor :tx_callback
  self.tx_callback = proc do |&block|
    ActiveRecord::Base.transaction(&block)
  end

  mattr_accessor :on_exception
  self.on_exception = proc do |exception|
    # Do something with this exception, i.e.
    # ExceptionNotifier.notify_exception(exception)
  end

  mattr_accessor :perform_jobs_in_tx
  self.perform_jobs_in_tx = true

  def self.setup
    fail 'Workhorse is already set up.' if @set_up
    yield self
    @set_up = true
  end
end

require 'workhorse/db_job'
require 'workhorse/performer'
require 'workhorse/poller'
require 'workhorse/pool'
require 'workhorse/worker'
require 'workhorse/jobs/run_rails_op'
require 'workhorse/jobs/cleanup_succeeded_jobs'

# Daemon functionality is not available on java platforms
if RUBY_PLATFORM != 'java'
  require 'workhorse/daemon'
  require 'workhorse/daemon/shell_handler'
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
workhorse-0.4.0 lib/workhorse.rb
workhorse-0.3.9 lib/workhorse.rb
workhorse-0.3.8 lib/workhorse.rb
workhorse-0.3.7 lib/workhorse.rb
workhorse-0.3.6 lib/workhorse.rb
workhorse-0.3.5 lib/workhorse.rb