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
-