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