module QueueClassicMatchers::QueueClassicRspec

Your code goes here…

Public Class Methods

find_by_args(queue_name, method, args) click to toggle source
# 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!() click to toggle source
# File lib/queue_classic_matchers.rb, line 17
def self.reset!
  QC.default_conn_adapter.execute 'DELETE FROM queue_classic_jobs'
end