Class: ActiveHook::Server::Retry

Inherits:
Object
  • Object
show all
Defined in:
lib/activehook/server/retry.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Retry

Returns a new instance of Retry.



4
5
6
 
# File 'lib/activehook/server/retry.rb', line 4

def initialize
  @done = false
end

Instance Method Details

#shutdown ⇒ Object 



20
21
22
 
# File 'lib/activehook/server/retry.rb', line 20

def shutdown
  @done = true
end

#start ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
 
# File 'lib/activehook/server/retry.rb', line 8

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