Module: Restash::ResqueServer

Defined in:
lib/restash/resque_server.rb

Class Method Summary collapse

Class Method Details

.included(base) ⇒ Object



6
7
8
9
10
11
12
13
14
15
16
17
18
19
# 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)
      success = Resque.enqueue_to(p['queue'], p['payload']['class'].constantize, *p['payload']['args'])
      { success: success }.to_json
    end
  end
end