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