forked from resque/resque
/
redis.rb
51 lines (45 loc) · 1.47 KB
/
redis.rb
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
module Resque
module Failure
# A Failure backend that stores exceptions in Redis. Very simple but
# works out of the box, along with support in the Resque web app.
class Redis < Base
def save
data = {
:failed_at => Time.now.strftime("%Y/%m/%d %H:%M:%S %Z"),
:payload => payload,
:exception => exception.class.to_s,
:error => exception.to_s,
:backtrace => filter_backtrace(Array(exception.backtrace)),
:worker => worker.to_s,
:queue => queue
}
data = Resque.encode(data)
Resque.redis.rpush(:failed, data)
end
def self.count
Resque.redis.llen(:failed).to_i
end
def self.all(start = 0, count = 1)
Resque.list_range(:failed, start, count)
end
def self.clear
Resque.redis.del(:failed)
end
def self.requeue(index)
item = all(index)
item['retried_at'] = Time.now.strftime("%Y/%m/%d %H:%M:%S")
Resque.redis.lset(:failed, index, Resque.encode(item))
Job.create(item['queue'], item['payload']['class'], *item['payload']['args'])
end
def self.remove(index)
id = rand(0xffffff)
Resque.redis.lset(:failed, index, id)
Resque.redis.lrem(:failed, 1, id)
end
def filter_backtrace(backtrace)
index = backtrace.index { |item| item.include?('/lib/resque/job.rb') }
backtrace.first(index.to_i)
end
end
end
end