Class: SayWhen::Poller::SimplePoller

Inherits:
Object
  • Object
show all
Includes:
BasePoller
Defined in:
lib/say_when/poller/simple_poller.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from BasePoller

#acquire, #error_tick_length, included, #job_error, #logger, #process, #process_jobs, #processor, #release, #reset_acquired, #reset_acquired_length, #storage, #tick, #tick_length

Constructor Details

#initialize(tick = nil) ⇒ SimplePoller

Returns a new instance of SimplePoller.



12
13
14
15
# File 'lib/say_when/poller/simple_poller.rb', line 12

def initialize(tick = nil)
  self.tick_length = tick.to_i if tick
  self.running = false
end

Instance Attribute Details

#runningObject

Returns the value of attribute running.



10
11
12
# File 'lib/say_when/poller/simple_poller.rb', line 10

def running
  @running
end

Instance Method Details

#running?Boolean

Returns:

  • (Boolean)


17
18
19
# File 'lib/say_when/poller/simple_poller.rb', line 17

def running?
  !!running
end

#startObject



21
22
23
24
25
26
27
28
29
# File 'lib/say_when/poller/simple_poller.rb', line 21

def start
  self.running = true
  logger.info "SayWhen::SimplePoller started"
  while running
    process_jobs
    tick
  end
  logger.info "SayWhen::SimplePoller stopped"
end

#stopObject



31
32
33
34
# File 'lib/say_when/poller/simple_poller.rb', line 31

def stop
  logger.info "SayWhen::SimplePoller stopping..."
  self.running = false
end