Contents

require 'sidekiq/cron/poller'

# For Cron we need to add some methods to Launcher
# so look at the code bellow.
#
# We are creating new cron poller instance and
# adding start and stop commands to launcher.
module Sidekiq
  module Cron
    module Launcher
      # Add cron poller to launcher.
      attr_reader :cron_poller

      # Add cron poller and execute normal initialize of Sidekiq launcher.
      def initialize(options)
        @cron_poller = Sidekiq::Cron::Poller.new
        super(options)
      end

      # Execute normal run of launcher and run cron poller.
      def run
        super
        cron_poller.start
      end

      # Execute normal quiet of launcher and quiet cron poller.
      def quiet
        cron_poller.terminate
        super
      end

      # Execute normal stop of launcher and stop cron poller.
      def stop
        cron_poller.terminate
        super
      end
    end
  end
end

Sidekiq.configure_server do
  require 'sidekiq/launcher'

  ::Sidekiq::Launcher.prepend(Sidekiq::Cron::Launcher)
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sidekiq-cron-1.7.0	lib/sidekiq/cron/launcher.rb