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 |