Module: Sidekiq::Sqs::Worker

Defined in:: lib/sidekiq-sqs/worker.rb

Instance Method Summary collapse

#client_push_bulk(args) ⇒ Object

args should be an array of single job arguments.
#perform_async_bulk(args) ⇒ Object

Instance Method Details

#client_push_bulk(args) ⇒ `Object`

args should be an array of single job arguments



9
10
11

# File 'lib/sidekiq-sqs/worker.rb', line 9

def client_push_bulk(args)
  Sidekiq::Client.push_bulk(args)
end

#perform_async_bulk(args) ⇒ `Object`



4
5
6

# File 'lib/sidekiq-sqs/worker.rb', line 4

def perform_async_bulk(args)
  client_push_bulk('class' => self, 'args' => args)
end