Class: Asynchronic::QueueEngine::Ost::Queue

Inherits:
Ost::Queue
  • Object
show all
Defined in:
lib/asynchronic/queue_engine/ost.rb

Instance Method Summary collapse

Instance Method Details

#empty? ⇒ Boolean

Returns:

  • (Boolean) 


47
48
49
 
# File 'lib/asynchronic/queue_engine/ost.rb', line 47

def empty?
  !redis.exists(key)
end

#pop ⇒ Object 



43
44
45
 
# File 'lib/asynchronic/queue_engine/ost.rb', line 43

def pop
  key.rpop
end

#size ⇒ Object 



51
52
53
 
# File 'lib/asynchronic/queue_engine/ost.rb', line 51

def size
  items.count
end

#to_a ⇒ Object 



55
56
57
 
# File 'lib/asynchronic/queue_engine/ost.rb', line 55

def to_a
  items.reverse
end