class Pushr::Daemon::FeedbackHandler

Attributes

name[R]
processor[R]
processor_path[R]

Public Class Methods

new(processor_path) click to toggle source
# File lib/pushr/daemon/feedback_handler.rb, line 6
def initialize(processor_path)
  @name = 'FeedbackHandler'
  @processor_path = processor_path
end

Public Instance Methods

start() click to toggle source
# File lib/pushr/daemon/feedback_handler.rb, line 11
def start
  return unless @processor_path
  require "#{Dir.pwd}/#{@processor_path}"
  @processor = Pushr::FeedbackProcessor.new

  Thread.new do
    loop do
      handle_next
      break if @stop
    end
  end
end
stop() click to toggle source
# File lib/pushr/daemon/feedback_handler.rb, line 24
def stop
  @stop = true
end

Protected Instance Methods

handle_next() click to toggle source
# File lib/pushr/daemon/feedback_handler.rb, line 30
def handle_next
  feedback = Pushr::Feedback.next
  @processor.process(feedback) if feedback
rescue => e
  Pushr::Daemon.logger.error(e)
end