Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Add some debug statements.

  • Loading branch information...
commit ef81c3f9dfe80bd4b101990d2c060df5935a5fe6 1 parent 41be60a
@MarkMenard authored
Showing with 7 additions and 7 deletions.
  1. +7 −7 lib/consumption_junction/message_processor.rb
View
14 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 "-+" * 25
- log "[ ConsumptionJunction::MessageProcessor ] BEGIN MessageProcessor#process_message #{message}"
+ puts "-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-"
+ puts "[ ConsumptionJunction::MessageProcessor ] BEGIN MessageProcessor#process_message #{message}"
self.message_count = message_count + 1
- log "[ ConsumptionJunction::MessageProcessor ] INFO MessageProcessor #{self} count = #{message_count}"
+ puts "[ ConsumptionJunction::MessageProcessor ] INFO MessageProcessor #{self} count = #{message_count}"
build_worker.process_message(message)
- log "[ ConsumptionJunction::MessageProcessor ] END MessageProcessor#process_message #{message}"
- log "-+" * 25
+ puts "[ ConsumptionJunction::MessageProcessor ] END MessageProcessor#process_message #{message}"
+ puts "-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-"
end
def build_worker
Please sign in to comment.
Something went wrong with that request. Please try again.