lib/metacrunch/redis/queue_writer.rb in metacrunch-3.1.1 vs lib/metacrunch/redis/queue_writer.rb in metacrunch-3.1.2

@@ -5,10 +5,12 @@
 
     def initialize(redis_connection_or_url, queue_name, options = {})
       @queue_name = queue_name
       raise ArgumentError, "queue_name must be a string" unless queue_name.is_a?(String)
 
+      @save_on_close = options.delete(:save_on_close) || true
+
       @redis = if redis_connection_or_url.is_a?(String)
         ::Redis.new(url: redis_connection_or_url)
       else
         redis_connection_or_url
       end
@@ -17,10 +19,13 @@
     def write(data)
       @redis.rpush(@queue_name, data.to_json)
     end
 
     def close
-      @redis.close if @redis
+      if @redis
+        @redis.bgsave if @save_on_close
+        @redis.close
+      end
     end
 
   end
 end