Method: Magent::GenericChannel#enqueue

Defined in:: lib/magent/generic_channel.rb

#enqueue(message, priority = 3) ⇒ `Object`



13
14
15

# File 'lib/magent/generic_channel.rb', line 13

def enqueue(message, priority = 3)
  collection.save({:_id => generate_uid, :message => message, :priority => priority, :created_at => Time.now.to_i, :retries => 0})
end