module RRRSpec::DispatcherQueue
Constants
- DEFAULT_TIMEOUT
- DISPATCHER_QUEUE_KEY
Public Class Methods
notify()
click to toggle source
Public: Check the active tasksets and dispatch them
# File lib/rrrspec/redis_models.rb, line 59 def self.notify RRRSpec.redis.rpush(DISPATCHER_QUEUE_KEY, 0) end
wait(timeout=DEFAULT_TIMEOUT)
click to toggle source
Public: Wait for the check command
# File lib/rrrspec/redis_models.rb, line 64 def self.wait(timeout=DEFAULT_TIMEOUT) RRRSpec.redis.blpop(DISPATCHER_QUEUE_KEY, timeout) end