Contents

module ActiveHook
  module Server
    class Retry
      def initialize
        @done = false
      end

      def start
        until @done
          ActiveHook.redis.with do |conn|
            conn.watch('ah:retry') do
              retries = retrieve_retries(conn)
              update_retries(conn, retries)
            end
          end
          sleep 2
        end
      end

      def shutdown
        @done = true
      end

      private

      def retrieve_retries(conn)
        conn.zrangebyscore('ah:retry', 0, Time.now.to_i)
      end

      def update_retries(conn, retries)
        if retries.any?
          conn.multi do |multi|
            multi.incrby('ah:total_retries', retries.count)
            multi.zrem('ah:retry', retries)
            multi.lpush('ah:queue', retries)
          end
        else
          conn.unwatch
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
activehook-0.1.9	lib/activehook/server/retry.rb
activehook-0.1.8	lib/activehook/server/retry.rb
activehook-0.1.7	lib/activehook/server/retry.rb
activehook-0.1.6	lib/activehook/server/retry.rb
activehook-0.1.5	lib/activehook/server/retry.rb