Class: Soda::Client
- Inherits:
-
Object
- Object
- Soda::Client
- Defined in:
- lib/soda/client.rb
Constant Summary collapse
- DEFAULTS =
{ "retry" => true, "delay" => 0, }
Class Method Summary collapse
Instance Method Summary collapse
Class Method Details
.middleware ⇒ Object
13 14 15 |
# File 'lib/soda/client.rb', line 13 def middleware Soda.client_middleware end |
.push(*args) ⇒ Object
9 10 11 |
# File 'lib/soda/client.rb', line 9 def push(*args) new.push(*args) end |
Instance Method Details
#push(item) ⇒ Object
18 19 20 21 22 23 24 25 26 27 28 |
# File 'lib/soda/client.rb', line 18 def push(item) copy = normalize!(item) self.class.middleware.use(item["klass"], copy, copy["queue"]) do jid = copy["id"] jid.tap do queue = Soda.queue(copy["queue"]) queue.push_in(copy["delay"], Soda.dump_json(copy)) end end end |