diff --git a/lib/consumption_junction/message_processor.rb b/lib/consumption_junction/message_processor.rb index 4fedf16..576c576 100644 --- a/lib/consumption_junction/message_processor.rb +++ b/lib/consumption_junction/message_processor.rb @@ -4,20 +4,20 @@ class ConsumptionJunction::MessageProcessor attr_accessor :message_count, :worker_class def initialize (worker_class) - log "[ ConsumptionJunction::MessageProcessor ] CREATE MessageProcessor for #{worker_class}" + puts "[ ConsumptionJunction::MessageProcessor ] CREATE MessageProcessor for #{worker_class}" self.worker_class = worker_class self.message_count = 0 - log "[ ConsumptionJunction::MessageProcessor ] END initialize()" + puts "[ ConsumptionJunction::MessageProcessor ] END initialize()" end def process_message (message) - log "-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-" - log "[ ConsumptionJunction::MessageProcessor ] BEGIN MessageProcessor#process_message using #{worker_class.to_s} #{message}" + puts "-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-" + puts "[ ConsumptionJunction::MessageProcessor ] BEGIN MessageProcessor#process_message using #{worker_class.to_s} #{message}" self.message_count = message_count + 1 - log "[ ConsumptionJunction::MessageProcessor ] INFO #{to_s}" + puts "[ ConsumptionJunction::MessageProcessor ] INFO #{to_s}" result = build_worker.process_message(message) - log "[ ConsumptionJunction::MessageProcessor ] END MessageProcessor#process_message result = #{result} for message = #{message}" - log "-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-" + puts "[ ConsumptionJunction::MessageProcessor ] END MessageProcessor#process_message result = #{result} for message = #{message}" + puts "-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-" result end