module SideSQS::Runner

Public Class Methods

run() click to toggle source
# File lib/sidesqs/runner.rb, line 3
def self.run
  @queue ||= AWS::SQS.new.queues.create(SideSQS.config.queue_name)
  @queue.poll do |message|
    data = JSON.parse(message.body)
    data['name'].constantize.new.perform(*data['args'])
  end
end