Contents

require "sidekiq"
require "concurrent"
require_relative "merger/version"
require_relative "merger/middleware"
require_relative "merger/config"
require_relative "merger/flusher"
require_relative "merger/logging_observer"

module Sidekiq::Merger
  LOGGER_TAG = self.name.freeze

  class << self
    attr_accessor :logger

    def create_task
      interval = Sidekiq::Merger::Config.poll_interval
      observer = Sidekiq::Merger::LoggingObserver.new(logger)
      flusher = Sidekiq::Merger::Flusher.new(logger)
      task = Concurrent::TimerTask.new(
        execution_interval: interval
      ) { flusher.flush }
      task.add_observer(observer)
      task
    end
  end

  self.logger = Sidekiq.logger
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
sidekiq-merger-0.0.9	lib/sidekiq/merger.rb
sidekiq-merger-0.0.8	lib/sidekiq/merger.rb