Method: Sqew::Backend::LevelDB#enqueue

Defined in:
lib/sqew/backend/leveldb.rb

#enqueue(payload) ⇒ Object



6
7
8
9
# File 'lib/sqew/backend/leveldb.rb', line 6

def enqueue(payload)
  id = Time.now.to_f.to_s
  queue.put(id, MultiJson.encode(klass:payload.klass.to_s, args:payload.args), :sync => true)
end