lib/redstream/consumer.rb in redstream-0.0.1 vs lib/redstream/consumer.rb in redstream-0.1.0

@@ -1,6 +1,5 @@
-
 require "thread"
 
 module Redstream
   # The Redstream::Consumer class to read messages from a specified redis
   # stream in batches.
@@ -90,11 +89,11 @@
 
         commit offset
       end
 
       sleep(5) unless got_lock
-    rescue => e
+    rescue StandardError => e
       @logger.error e
 
       sleep 5
 
       retry
@@ -110,6 +109,5 @@
     def commit(offset)
       @redis.set Redstream.offset_key_name(stream_name: @stream_name, consumer_name: @name), offset
     end
   end
 end
-