Contents

# encoding: utf-8

begin
  require 'celluloid/current'
rescue LoadError
  require 'celluloid'
end

require 'logger'
require 'say_when/poller/base_poller'

module SayWhen
  module Poller
    class CelluloidPoller
      include Celluloid
      include SayWhen::Poller::BasePoller

      def initialize(tick = nil)
        @tick_length = tick.to_i if tick
        start
      end

      def start
        @tick_timer = every(tick_length) { process_jobs }
      end

      def stop
        if @tick_timer
          @tick_timer.cancel
          @tick_timer = nil
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
say_when-2.2.2	lib/say_when/poller/celluloid_poller.rb
say_when-2.2.1	lib/say_when/poller/celluloid_poller.rb
say_when-2.2.0	lib/say_when/poller/celluloid_poller.rb
say_when-2.1.1	lib/say_when/poller/celluloid_poller.rb