gistfile1.rb

class ConsumptionJunction::MessageProcessor
  include Celluloid
  
  attr_accessor :message_count, :worker_class
  
  def initialize (worker_class)
    puts "[ ConsumptionJunction::MessageProcessor ] CREATE MessageProcessor for #{worker_class}"
    self.worker_class = worker_class
    self.message_count = 0
    puts "[ ConsumptionJunction::MessageProcessor ] END initialize()"
  end
  
  def process_message (message)
    puts "-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-"
    puts "[ ConsumptionJunction::MessageProcessor ] BEGIN MessageProcessor#process_message using #{worker_class.to_s} #{message}"
    self.message_count = message_count + 1
    puts "[ ConsumptionJunction::MessageProcessor ] INFO #{to_s}"
    worker = build_worker(message)
    begin
      result = worker.process_message
    rescue => e
      if worker.respond_to?(:on_error)
        worker.on_error(e)
      end
    end
    puts "[ ConsumptionJunction::MessageProcessor ] END MessageProcessor#process_message result = #{result} for message = #{message}"
    puts "-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-"
    result
  end
  
  def build_worker (message)
    worker_class.new(message)
  end
  
  def log (message)
    if defined? ::Rails
      ::Rails.logger.info message
    else
      log message
    end
  end
  
  def to_s
    "#{self.class.to_s}< worker_class => #{worker_class.to_s}, message_count => #{message_count} >"
  end
end