Method: Qup::Adapter::Redis::Queue#initialize

Defined in:
lib/qup/adapter/redis/queue.rb

#initialize(uri, name, topic_name = nil) ⇒ Queue

Internal: create a new Queue

uri - the connection uri for the Redis Client name - the String name of the Queue topic_name - (optional) the String name of a parent topic

Returns a new Queue.



17
18
19
20
21
# File 'lib/qup/adapter/redis/queue.rb', line 17

def initialize( uri, name, topic_name = nil )
  super uri, name
  @topic_name = topic_name
  @open_messages = {}
end