Method: Lowkiq::Queue::Queue#initialize

Defined in:
lib/lowkiq/queue/queue.rb

#initialize(redis_pool, name, shards_count) ⇒ Queue

Returns a new instance of Queue.



6
7
8
9
10
11
12
13
 
# File 'lib/lowkiq/queue/queue.rb', line 6

def initialize(redis_pool, name, shards_count)
  @pool = redis_pool
  @name = name
  @shards_count = shards_count
  @timestamp = Utils::Timestamp.method(:now)
  @keys = Keys.new name
  @fetch = Fetch.new name
end