Class: Resque::Failure::Base
- Inherits:
-
Object
- Object
- Resque::Failure::Base
- Defined in:
- lib/resque/failure/base.rb
Overview
All Failure classes are expected to subclass Base.
When a job fails, a new instance of your Failure backend is created and #save is called.
Instance Attribute Summary collapse
-
#exception ⇒ Object
The exception object raised by the failed job.
-
#payload ⇒ Object
The payload object associated with the failed job.
-
#queue ⇒ Object
The string name of the queue from which the failed job was pulled.
-
#worker ⇒ Object
The worker object who detected the failure.
Class Method Summary collapse
-
.all(start = 0, count = 1) ⇒ Object
Returns a paginated array of failure objects.
-
.clear ⇒ Object
Clear all failure objects.
-
.count ⇒ Object
The number of failures.
- .remove(index) ⇒ Object
- .requeue(index) ⇒ Object
-
.url ⇒ Object
A URL where someone can go to view failures.
Instance Method Summary collapse
-
#initialize(exception, worker, queue, payload) ⇒ Base
constructor
A new instance of Base.
-
#log(message) ⇒ Object
Logging!.
-
#save ⇒ Object
When a job fails, a new instance of your Failure backend is created and #save is called.
Constructor Details
#initialize(exception, worker, queue, payload) ⇒ Base
Returns a new instance of Base.
20 21 22 23 24 25 |
# File 'lib/resque/failure/base.rb', line 20 def initialize(exception, worker, queue, payload) @exception = exception @worker = worker @queue = queue @payload = payload end |
Instance Attribute Details
#exception ⇒ Object
The exception object raised by the failed job
9 10 11 |
# File 'lib/resque/failure/base.rb', line 9 def exception @exception end |
#payload ⇒ Object
The payload object associated with the failed job
18 19 20 |
# File 'lib/resque/failure/base.rb', line 18 def payload @payload end |
#queue ⇒ Object
The string name of the queue from which the failed job was pulled
15 16 17 |
# File 'lib/resque/failure/base.rb', line 15 def queue @queue end |
#worker ⇒ Object
The worker object who detected the failure
12 13 14 |
# File 'lib/resque/failure/base.rb', line 12 def worker @worker end |
Class Method Details
.all(start = 0, count = 1) ⇒ Object
Returns a paginated array of failure objects.
40 41 42 |
# File 'lib/resque/failure/base.rb', line 40 def self.all(start = 0, count = 1) [] end |
.clear ⇒ Object
Clear all failure objects
49 50 |
# File 'lib/resque/failure/base.rb', line 49 def self.clear end |
.count ⇒ Object
The number of failures.
35 36 37 |
# File 'lib/resque/failure/base.rb', line 35 def self.count 0 end |
.remove(index) ⇒ Object
55 56 |
# File 'lib/resque/failure/base.rb', line 55 def self.remove(index) end |
.requeue(index) ⇒ Object
52 53 |
# File 'lib/resque/failure/base.rb', line 52 def self.requeue(index) end |
.url ⇒ Object
A URL where someone can go to view failures.
45 46 |
# File 'lib/resque/failure/base.rb', line 45 def self.url end |
Instance Method Details
#log(message) ⇒ Object
Logging!
59 60 61 |
# File 'lib/resque/failure/base.rb', line 59 def log() @worker.log() end |
#save ⇒ Object
When a job fails, a new instance of your Failure backend is created and #save is called.
This is where you POST or PUT or whatever to your Failure service.
31 32 |
# File 'lib/resque/failure/base.rb', line 31 def save end |