lib/rising_dragon/sqs/worker.rb in rising_dragon-0.4.0 vs lib/rising_dragon/sqs/worker.rb in rising_dragon-0.5.0

@@ -35,11 +35,11 @@
         def emitter
           @emitter ||= ::RisingDragon::SQS::Emitter.new
         end
       end
 
-      def perform(sqs_msg, body)
-        self.class.emitter.emit_sqs_msg(sqs_msg, body)
+      def perform(_sqs_msg, body)
+        self.class.emitter.emit_sns_msg(body)
       rescue StandardError => e
         rescue_from(e)
       end
 
       def rescue_from(e)