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

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

Instance Method Summary collapse

Constructor Details

#initialize(name, redis) ⇒ Queue

Returns a new instance of Queue.



58
59
60
61
 
# File 'lib/asynchronic/queue_engine/ost.rb', line 58

def initialize(name, redis)
  super name
  self.redis = redis
end

Instance Method Details

#empty? ⇒ Boolean

Returns:

  • (Boolean) 


67
68
69
 
# File 'lib/asynchronic/queue_engine/ost.rb', line 67

def empty?
  redis.call!('EXISTS', key) == 0
end

#pop ⇒ Object 



63
64
65
 
# File 'lib/asynchronic/queue_engine/ost.rb', line 63

def pop
  redis.call! 'RPOP', key
end

#size ⇒ Object 



71
72
73
 
# File 'lib/asynchronic/queue_engine/ost.rb', line 71

def size
  items.count
end

#to_a ⇒ Object 



75
76
77
 
# File 'lib/asynchronic/queue_engine/ost.rb', line 75

def to_a
  items.reverse
end