Contents

#require  Sidekiq original launcher
require 'sidekiq/launcher'

#require cron poller
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
  class Launcher

    #Add cron poller to launcher
    attr_reader :cron_poller


    #remember old initialize
    alias_method :old_initialize, :initialize

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


    #remember old run
    alias_method :old_run, :run

    #execute normal run of launcher and run cron poller
    def run
      old_run
      cron_poller.async.poll(true)
    end


    #remember old stop
    alias_method :old_stop, :stop

    #execute normal stop of launcher and stop cron poller
    def stop
      cron_poller.async.terminate if poller.alive?
      old_stop
    end

  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
sidekiq-cron-0.3.1	lib/sidekiq/cron/launcher.rb
sidekiq-cron-0.3.0	lib/sidekiq/cron/launcher.rb
sidekiq-cron-0.2.0	lib/sidekiq/cron/launcher.rb
sidekiq-cron-0.1.9	lib/sidekiq/cron/launcher.rb
sidekiq-cron-0.1.8	lib/sidekiq/cron/launcher.rb
sidekiq-cron-0.1.7	lib/sidekiq/cron/launcher.rb
sidekiq-cron-0.1.6	lib/sidekiq/cron/launcher.rb
sidekiq-cron-0.1.5	lib/sidekiq/cron/launcher.rb
sidekiq-cron-0.1.4	lib/sidekiq/cron/launcher.rb
sidekiq-cron-0.1.3	lib/sidekiq/cron/launcher.rb
sidekiq-cron-0.1.2	lib/sidekiq/cron/launcher.rb