File tree Expand file tree Collapse file tree 3 files changed +12
-16
lines changed Expand file tree Collapse file tree 3 files changed +12
-16
lines changed Original file line number Diff line number Diff line change @@ -273,8 +273,16 @@ def reserve(queue)
273
273
# If no queue can be inferred this method will raise a `Resque::NoQueueError`
274
274
#
275
275
# If given klass is nil this method will raise a `Resque::NoClassError`
276
- def validate! ( klass )
277
- Job . validate! ( klass )
276
+ def validate ( klass , queue = nil )
277
+ queue ||= queue_from_class ( klass )
278
+
279
+ if !queue
280
+ raise NoQueueError . new ( "Jobs must be placed onto a queue." )
281
+ end
282
+
283
+ if klass . to_s . empty?
284
+ raise NoClassError . new ( "Jobs must be given a class." )
285
+ end
278
286
end
279
287
280
288
Original file line number Diff line number Diff line change @@ -40,7 +40,7 @@ def initialize(queue, payload)
40
40
#
41
41
# Raises an exception if no queue or class is given.
42
42
def self . create ( queue , klass , *args )
43
- validate! ( klass , queue )
43
+ Resque . validate ( klass , queue )
44
44
45
45
if Resque . inline?
46
46
constantize ( klass ) . perform ( *decode ( encode ( args ) ) )
@@ -98,18 +98,6 @@ def self.reserve(queue)
98
98
new ( queue , payload )
99
99
end
100
100
101
-
102
- # Validates if the given klass could be a valid Resque job
103
- def self . validate! ( klass , queue = Resque . queue_from_class ( klass ) )
104
- if !queue
105
- raise NoQueueError . new ( "Jobs must be placed onto a queue." )
106
- end
107
-
108
- if klass . to_s . empty?
109
- raise NoClassError . new ( "Jobs must be given a class." )
110
- end
111
- end
112
-
113
101
# Attempts to perform the work represented by this job instance.
114
102
# Calls #perform on the class given in the payload with the
115
103
# arguments given in the payload.
Original file line number Diff line number Diff line change 130
130
131
131
test "validates job for queue presence" do
132
132
assert_raises Resque ::NoQueueError do
133
- Resque . validate! ( SomeJob )
133
+ Resque . validate ( SomeJob )
134
134
end
135
135
end
136
136
You can’t perform that action at this time.
0 commit comments