Contents

# 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'
          end
          define_singleton_method(:inspect, method(:to_s))

          block ||= ->(job) { redis_connections }

          define_method :around_perform do |job|
            Array(block.call(job)).each do |redis|
              redis.client.reconnect
            end

            super(job)
          end
        end
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
qless-0.12.0	lib/qless/middleware/redis_reconnect.rb
qless-0.11.0	lib/qless/middleware/redis_reconnect.rb
qless-0.10.5	lib/qless/middleware/redis_reconnect.rb
qless-0.10.4	lib/qless/middleware/redis_reconnect.rb
qless-0.10.3	lib/qless/middleware/redis_reconnect.rb
qless-0.10.2	lib/qless/middleware/redis_reconnect.rb
qless-0.10.1	lib/qless/middleware/redis_reconnect.rb
qless-0.10.0	lib/qless/middleware/redis_reconnect.rb