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