lib/alephant/sequencer/sequencer.rb in alephant-sequencer-0.0.2 vs lib/alephant/sequencer/sequencer.rb in alephant-sequencer-0.0.3

@@ -1,10 +1,12 @@
 require 'jsonpath'
+require 'alephant/logger'
 
 module Alephant
   module Sequencer
     class Sequencer
+      include ::Alephant::Logger
       attr_reader :ident, :jsonpath
 
       def initialize(sequence_table, id, sequence_path = nil)
         @mutex = Mutex.new
         @sequence_table = sequence_table
@@ -17,14 +19,16 @@
       def sequential?(data)
         get_last_seen < sequence_id_from(data)
       end
 
       def delete!
+        logger.info("Sequencer.delete!: #{ident}")
         @sequence_table.delete_item!(ident)
       end
 
       def set_last_seen(data)
         last_seen_id = sequence_id_from(data)
+        logger.info("Sequencer.set_last_seen: #{last_seen_id}")
 
         @sequence_table.set_sequence_for(ident, last_seen_id)
       end
 
       def get_last_seen