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