Class: SidekiqPublisher::Client
- Inherits:
-
Sidekiq::Client
- Object
- Sidekiq::Client
- SidekiqPublisher::Client
- Defined in:
- lib/sidekiq_publisher/client.rb
Instance Method Summary collapse
Instance Method Details
#bulk_push(items) ⇒ Object
7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 |
# File 'lib/sidekiq_publisher/client.rb', line 7 def bulk_push(items) payloads = items.map do |item| normed = normalize_item(item) process_single(item["class"], normed) end.compact pushed = 0 with_connection do |conn| conn.multi do payloads.each do |payload| atomic_push(conn, [payload]) pushed += 1 end end end pushed end |