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
|
# File 'lib/restash/resque_server.rb', line 6
def self.included(base)
base.class_eval do
get '/restash/ping' do
{ status: :ok }.to_json
end
post '/restash/retry' do
p = JSON.parse(request.body.read)
queue = p['queue']
klass = p['payload']['class']
args = p['payload']['args']
success = false
enqueue = :not_enqueued
begin
success = Resque.enqueue_to(queue, klass.constantize, *args)
enqueue = :with_resque_enqueue_to
rescue NoMethodError => e
Resque.push(queue, :class => klass.to_s, :args => args)
success = true
enqueue = :with_resque_push
end
{ success: success, enqueue: enqueue }.to_json
end
end
end
|