Accept one new type of exception in retry utils

wistia · Jan 29, 2019 · 2571e34 · 2571e34
1 parent d869114
commit 2571e34
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/nsq/retry.rb b/lib/nsq/retry.rb
@@ -19,7 +19,7 @@ def self.with_retries(opts = {}, &block)
         attempts += 1
         return block.call(attempts)
 
-      rescue UnexpectedFrameError, Errno::ECONNREFUSED, Errno::ECONNRESET, Errno::EHOSTUNREACH,
+      rescue UnexpectedFrameError, ErrorFrameException, Errno::ECONNREFUSED, Errno::ECONNRESET, Errno::EHOSTUNREACH,
              Errno::ENETDOWN, Errno::ENETUNREACH, Errno::ETIMEDOUT, Timeout::Error => ex
 
         raise ex if attempts >= max_attempts