Module: QueueClassicMatchers::QueueClassicRspec

Defined in:
lib/queue_classic_matchers.rb

Overview

Your code goes here…

Class Method Summary collapse

Class Method Details

.find_by_args(queue_name, method, args) ⇒ Object 



10
11
12
13
14
15
 
# File 'lib/queue_classic_matchers.rb', line 10

def self.find_by_args(queue_name, method, args)
  q = 'SELECT * FROM queue_classic_jobs WHERE q_name = $1 AND method = $2 AND args::text = $3'
  result = QC.default_conn_adapter.execute q, queue_name, method, JSON.dump(args)
  result = [result] unless Array === result
  result.compact
end

.reset! ⇒ Object 



17
18
19
 
# File 'lib/queue_classic_matchers.rb', line 17

def self.reset!
  QC.default_conn_adapter.execute 'DELETE FROM queue_classic_jobs'
end