Method: PerfectQueue::Backend::RDBBackend#cancel

Defined in:
lib/perfectqueue/backend/rdb.rb

#cancel(id, delete_timeout = 3600, now = Process.clock_gettime(Process::CLOCK_REALTIME, :second)) ⇒ Object 



51
52
53
54
55
56
 
# File 'lib/perfectqueue/backend/rdb.rb', line 51

def cancel(id, delete_timeout=3600, now=Process.clock_gettime(Process::CLOCK_REALTIME, :second))
  connect {
    n = @db["UPDATE `#{@table}` SET timeout=?, created_at=NULL, resource=NULL WHERE id=? AND created_at IS NOT NULL;", now+delete_timeout-DELETE_OFFSET, id].update
    return n > 0
  }
end