Class: Box::Office::Janitor

Inherits:
Object
  • Object
show all
Extended by:
Connection
Defined in:
lib/box/office/janitor.rb

Constant Summary collapse

LOCKED_QUEUE_KEY = 
"box-office:locked:queues"

Class Method Summary collapse

Methods included from Connection

with_connection

Class Method Details

.lock(queue_name) ⇒ Object 



10
11
12
 
# File 'lib/box/office/janitor.rb', line 10

def lock(queue_name)
  with_connection { |conn| conn.sadd(LOCKED_QUEUE_KEY, queue_name) }
end

.locked?(queue_name) ⇒ Boolean

Returns:

  • (Boolean) 


14
15
16
 
# File 'lib/box/office/janitor.rb', line 14

def locked?(queue_name)
  with_connection { |conn| conn.sismember(LOCKED_QUEUE_KEY, queue_name) }
end

.locked_queues ⇒ Object 



18
19
20
 
# File 'lib/box/office/janitor.rb', line 18

def locked_queues
  with_connection { |conn| conn.smembers LOCKED_QUEUE_KEY }
end

.unlock(queue_name) ⇒ Object 



22
23
24
 
# File 'lib/box/office/janitor.rb', line 22

def unlock(queue_name)
  with_connection { |conn| conn.srem(LOCKED_QUEUE_KEY, queue_name) }
end