Method: Roundhouse::Worker::ClassMethods#client_push

Defined in:
lib/roundhouse/worker.rb

#client_push(item) ⇒ Object

:nodoc:



83
84
85
86
 
# File 'lib/roundhouse/worker.rb', line 83

def client_push(item) # :nodoc:
  pool = Thread.current[:roundhouse_via_pool] || get_roundhouse_options['pool'] || Roundhouse.redis_pool
  Roundhouse::Client.new(pool).push(item.stringify_keys)
end