Module: QueueClassicPlus

Defined in:
lib/queue_classic_plus.rb,
lib/queue_classic_plus/base.rb,
lib/queue_classic_plus/worker.rb,
lib/queue_classic_plus/metrics.rb,
lib/queue_classic_plus/version.rb,
lib/queue_classic_plus/inflector.rb,
lib/queue_classic_plus/update_metrics.rb,
lib/queue_classic_plus/inheritable_attr.rb

Defined Under Namespace

Modules: Inflector, InheritableAttribute, UpdateMetrics Classes: Base, CustomWorker, Empty, Metrics

Constant Summary collapse

VERSION = 
"1.1.0"

Class Method Summary collapse

Class Method Details

.demigrate(c = QC::default_conn_adapter.connection) ⇒ Object 



22
23
24
25
26
 
# 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 ⇒ Object 



28
29
30
 
# File 'lib/queue_classic_plus.rb', line 28

def self.exception_handler
  @exception_handler ||= ->(exception, job) { nil }
end

.exception_handler=(handler) ⇒ Object 



32
33
34
 
# File 'lib/queue_classic_plus.rb', line 32

def self.exception_handler=(handler)
  @exception_handler = handler
end

.logger ⇒ Object 



40
41
42
 
# File 'lib/queue_classic_plus.rb', line 40

def self.logger
  @logger ||= defined?(Rails) ? Rails.logger : Logger.new(STDOUT)
end

.logger=(l) ⇒ Object 



44
45
46
 
# File 'lib/queue_classic_plus.rb', line 44

def self.logger=(l)
  @logger = l
end

.migrate(c = QC::default_conn_adapter.connection) ⇒ Object 



16
17
18
19
20
 
# 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 ⇒ Object 



36
37
38
 
# File 'lib/queue_classic_plus.rb', line 36

def self.update_metrics
  UpdateMetrics.update
end