Method: Qu::Backend::Mongo#enqueue

Defined in:
lib/qu/backend/mongo.rb

#enqueue(payload) ⇒ Object 



41
42
43
44
45
46
47
 
# File 'lib/qu/backend/mongo.rb', line 41

def enqueue(payload)
  payload.id = BSON::ObjectId.new
  jobs(payload.queue).insert({:_id => payload.id, :klass => payload.klass.to_s, :args => payload.args})
  self[:queues].update({:name => payload.queue}, {:name => payload.queue}, :upsert => true)
  logger.debug { "Enqueued job #{payload}" }
  payload
end