Module: RisingDragon::SQS::Worker

Defined in:
lib/rising_dragon/sqs/worker.rb

Defined Under Namespace

Modules: ClassMethods

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(base) ⇒ Object 



4
5
6
7
8
9
 
# 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

Instance Method Details

#perform(_sqs_msg, body) ⇒ Object 



40
41
42
43
44
 
# 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) ⇒ Object 



46
47
48
49
 
# File 'lib/rising_dragon/sqs/worker.rb', line 46

def rescue_from(e)
  # overwrite here
  raise e
end