class Asynchronic::QueueEngine::Ost::Queue

Public Class Methods

new(name, redis) click to toggle source
Calls superclass method
# File lib/asynchronic/queue_engine/ost.rb, line 58
def initialize(name, redis)
  super name
  self.redis = redis
end

Public Instance Methods

empty?() click to toggle source
# File lib/asynchronic/queue_engine/ost.rb, line 67
def empty?
  redis.call!('EXISTS', key) == 0
end
pop() click to toggle source
# File lib/asynchronic/queue_engine/ost.rb, line 63
def pop
  redis.call! 'RPOP', key
end
size() click to toggle source
# File lib/asynchronic/queue_engine/ost.rb, line 71
def size
  items.count
end
to_a() click to toggle source
# File lib/asynchronic/queue_engine/ost.rb, line 75
def to_a
  items.reverse
end