module RisingDragon::SQS::Worker

Public Class Methods

included(base) click to toggle source
# File lib/rising_dragon/sqs/worker.rb, line 4
def self.included(base)
  base.class_eval do
    include Shoryuken::Worker
  end
  base.extend(ClassMethods)
end

Public Instance Methods

perform(_sqs_msg, body) click to toggle source
# File lib/rising_dragon/sqs/worker.rb, line 40
def perform(_sqs_msg, body)
  self.class.emitter.emit_sns_msg(body)
rescue StandardError => e
  rescue_from(e)
end
rescue_from(e) click to toggle source
# File lib/rising_dragon/sqs/worker.rb, line 46
def rescue_from(e)
  # overwrite here
  raise e
end