class Sidekiq::Merger::Flusher

Public Class Methods

new(logger) click to toggle source
# File lib/sidekiq/merger/flusher.rb, line 2
def initialize(logger)
  @logger = logger
end

Public Instance Methods

flush() click to toggle source
# File lib/sidekiq/merger/flusher.rb, line 6
def flush
  merges = Sidekiq::Merger::Merge.all.select(&:can_flush?)
  unless merges.empty?
    @logger.info(
      "[Sidekiq::Merger] Trying to flush merged queues: #{merges.map(&:full_merge_key).join(",")}"
    )
    merges.each(&:flush)
  end
end