Class: ReMQ::Queue

Inherits:
Object
  • Object
show all
Defined in:
lib/ReMQ/Queue.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name) ⇒ Queue

Create a new queue.

Parameters:

  • name (String) —

    queue name



11
12
13
 
# File 'lib/ReMQ/Queue.rb', line 11

def initialize(name)
  @name = ReMQ.normalize_queue_name(name)
end

Instance Attribute Details

#name ⇒ Object (readonly)

Returns the value of attribute name.



6
7
8
 
# File 'lib/ReMQ/Queue.rb', line 6

def name
  @name
end

Instance Method Details

#enqueue(*args) ⇒ Boolean

Add a job to the queue.

Parameters:

  • class (String) —

    Job class name

  • params (mixed) —

    Job parameters

Returns:

  • (Boolean) —

    true if job was queued

Raises:



21
22
23
24
25
26
 
# File 'lib/ReMQ/Queue.rb', line 21

def enqueue(*args)
  body = args.to_json
  if ReMQ.is_valid_job?(args.first)
    ReMQ.redis().rpush(name, body)
  end
end