Module: RailsIron::Worker::ClassMethods

Defined in:
lib/rails_iron/worker.rb

Instance Method Summary collapse

Instance Method Details

#iron_worker ⇒ Object 



10
11
12
 
# File 'lib/rails_iron/worker.rb', line 10

def iron_worker
  IronWorkerNG::Client.new
end

#perform_async(*args) ⇒ Object 



14
15
16
 
# File 'lib/rails_iron/worker.rb', line 14

def perform_async(*args)
  queue({params: args})
end

#queue(payload = nil) ⇒ Object 



18
19
20
21
22
23
24
 
# File 'lib/rails_iron/worker.rb', line 18

def queue(payload = nil)
  begin
    iron_worker.tasks.create(self.name, payload)
  rescue Net::HTTP::Persistent::Error => t
    raise RailsIron::TemporaryError, t.message
  end
end