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