Module: Wurk::Client::Buffered::InstanceMethods

Defined in:
lib/wurk/client/buffered.rb

Overview

Wraps Wurk::Client. push / push_bulk drain the buffer first; raw_push catches ConnectionError and buffers non-batched payloads.

Instance Method Summary collapse

Instance Method Details

#push(item) ⇒ Object 



297
298
299
300
 
# File 'lib/wurk/client/buffered.rb', line 297

def push(item)
  Buffered.drain!(self)
  super
end

#push_bulk(items) ⇒ Object 



302
303
304
305
 
# File 'lib/wurk/client/buffered.rb', line 302

def push_bulk(items)
  Buffered.drain!(self)
  super
end