module Sidekiq::Grouping

Constants

VERSION

Attributes

logger[W]

Public Class Methods

force_flush_for_test!() click to toggle source
# File lib/sidekiq/grouping.rb, line 27
def force_flush_for_test!
  Sidekiq::Grouping::Flusher.new.force_flush_for_test!
end
logger() click to toggle source
# File lib/sidekiq/grouping.rb, line 23
def logger
  @logger ||= Sidekiq.logger
end
start!() click to toggle source
# File lib/sidekiq/grouping.rb, line 31
def start!
  interval = Sidekiq::Grouping::Config.poll_interval
  @observer = Sidekiq::Grouping::FlusherObserver.new
  @task = Concurrent::TimerTask.new(
    execution_interval: interval
  ) { Sidekiq::Grouping::Flusher.new.flush }
  @task.add_observer(@observer)
  logger.info(
    "[Sidekiq::Grouping] Started polling batches every " \
    "#{interval} seconds"
  )
  @task.execute
end