Class: Kyklos::Adapters::ShoryukenAdapter::Worker

Inherits:
Object
  • Object
show all
Includes:
Shoryuken::Worker
Defined in:
lib/kyklos/adapters/shoryuken_adapter.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.config_pathObject



159
160
161
# File 'lib/kyklos/adapters/shoryuken_adapter.rb', line 159

def self.config_path
  @@config_path
end

.config_path=(config_path) ⇒ Object



155
156
157
# File 'lib/kyklos/adapters/shoryuken_adapter.rb', line 155

def self.config_path=(config_path)
  @@config_path = config_path
end

Instance Method Details

#perform(sqs_msg, body) ⇒ Object



163
164
165
166
167
168
169
# File 'lib/kyklos/adapters/shoryuken_adapter.rb', line 163

def perform(sqs_msg, body)
  data = JSON.load(body)
  job_id =data['job_id']
  if job_id
    kyklos.run(job_id)
  end
end