Skip to content

Commit

Permalink
More debug
Browse files Browse the repository at this point in the history
  • Loading branch information
MarkMenard committed Aug 9, 2011
1 parent 5976843 commit 2bd0c4a
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions lib/consumption_junction/message_processor.rb
Expand Up @@ -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

Expand Down

0 comments on commit 2bd0c4a

Please sign in to comment.