module QueueClassicPlus

Constants

VERSION

Public Class Methods

demigrate(c = QC::default_conn_adapter.connection) click to toggle source
# File lib/queue_classic_plus.rb, line 22
def self.demigrate(c = QC::default_conn_adapter.connection)
  conn = QC::ConnAdapter.new(c)
  conn.execute("ALTER TABLE queue_classic_jobs DROP COLUMN last_error")
  conn.execute("ALTER TABLE queue_classic_jobs DROP COLUMN remaining_retries")
end
exception_handler() click to toggle source
# File lib/queue_classic_plus.rb, line 28
def self.exception_handler
  @exception_handler ||= ->(exception, job) { nil }
end
exception_handler=(handler) click to toggle source
# File lib/queue_classic_plus.rb, line 32
def self.exception_handler=(handler)
  @exception_handler = handler
end
logger() click to toggle source
# File lib/queue_classic_plus.rb, line 40
def self.logger
  @logger ||= defined?(Rails) ? Rails.logger : Logger.new(STDOUT)
end
logger=(l) click to toggle source
# File lib/queue_classic_plus.rb, line 44
def self.logger=(l)
  @logger = l
end
migrate(c = QC::default_conn_adapter.connection) click to toggle source
# File lib/queue_classic_plus.rb, line 16
def self.migrate(c = QC::default_conn_adapter.connection)
  conn = QC::ConnAdapter.new(c)
  conn.execute("ALTER TABLE queue_classic_jobs ADD COLUMN last_error TEXT")
  conn.execute("ALTER TABLE queue_classic_jobs ADD COLUMN remaining_retries INTEGER")
end
update_metrics() click to toggle source
# File lib/queue_classic_plus.rb, line 36
def self.update_metrics
  UpdateMetrics.update
end