lib/toiler/actor/processor.rb in toiler-0.5.1.pre7 vs lib/toiler/actor/processor.rb in toiler-0.5.1.pre9

@@ -92,15 +92,16 @@
       def visibility_extender(queue_visibility, sqs_msg, body)
         return unless auto_visibility_timeout?
 
         interval = [1, queue_visibility / 3].max
         Concurrent::TimerTask.execute execution_interval: interval,
-                                      timeout_interval: interval do
+                                      timeout_interval: interval do |task|
           begin
             sqs_msg.visibility_timeout = queue_visibility
             yield sqs_msg, body if block_given?
           rescue StandardError => e
-            error "Processor #{queue} failed to extend visibility of message: #{e.message}\n#{e.backtrace.join("\n")}"
+            error "Processor #{queue} failed to extend visibility of message - #{e.class}: #{e.message}\n#{e.backtrace.join("\n")}"
+            task.shutdown if e.message.include?('ReceiptHandle is invalid')
           end
         end
       end
 
       def get_body(sqs_msg)