class Kyklos::Adapters::ShoryukenAdapter::Worker

Public Class Methods

config_path() click to toggle source
# File lib/kyklos/adapters/shoryuken_adapter.rb, line 131
def self.config_path
  @@config_path
end
config_path=(config_path) click to toggle source
# File lib/kyklos/adapters/shoryuken_adapter.rb, line 127
def self.config_path=(config_path)
  @@config_path = config_path
end

Public Instance Methods

perform(sqs_msg, body) click to toggle source
# File lib/kyklos/adapters/shoryuken_adapter.rb, line 135
def perform(sqs_msg, body)
  data = JSON.load(body)
  job_id =data['job_id']
  if job_id
    kyklos.run(job_id)
  end
end

Private Instance Methods

kyklos() click to toggle source
# File lib/kyklos/adapters/shoryuken_adapter.rb, line 145
def kyklos
  Kyklos.parse(File.read(self.class.config_path))
end