lib/rabbit/receiving/worker.rb in rabbit_messaging-0.12.1 vs lib/rabbit/receiving/worker.rb in rabbit_messaging-0.13.0
- old
+ new
@@ -25,8 +25,10 @@
end
def handle_error!(error)
raise if Rabbit.config.environment == :test
Rabbit.config.exception_notifier.call(error)
+ # wait to prevent queue overflow
+ sleep 1
requeue!
end
end