lib/qless/middleware/redis_reconnect.rb in qless-0.9.3 vs lib/qless/middleware/redis_reconnect.rb in qless-0.10.0

- old
+ new

@@ -1,15 +1,19 @@ +# Encoding: utf-8 + module Qless module Middleware + # A module for reconnecting to redis for each job module RedisReconnect def self.new(*redis_connections, &block) Module.new do define_singleton_method :to_s do - "Qless::Middleware::RedisReconnect" + 'Qless::Middleware::RedisReconnect' end + define_singleton_method(:inspect, method(:to_s)) - block ||= lambda { |job| redis_connections } + block ||= ->(job) { redis_connections } define_method :around_perform do |job| Array(block.call(job)).each do |redis| redis.client.reconnect end @@ -19,6 +23,5 @@ end end end end end -