Method: ZSpec::Queue#cleanup

Defined in:
lib/zspec/queue.rb

#cleanup(expire_seconds = EXPIRE_SECONDS) ⇒ Object 



22
23
24
25
26
27
28
29
 
# File 'lib/zspec/queue.rb', line 22

def cleanup(expire_seconds = EXPIRE_SECONDS)
  @sink.expire(@counter_name, expire_seconds)
  @sink.expire(@pending_queue_name, expire_seconds)
  @sink.expire(@processing_queue_name, expire_seconds)
  @sink.expire(@done_queue_name, expire_seconds)
  @sink.expire(@metadata_hash_name, expire_seconds)
  @sink.expire(@workers_ready_key_name, expire_seconds)
end