lib/alephant/sequencer/sequencer.rb in alephant-sequencer-1.1.0 vs lib/alephant/sequencer/sequencer.rb in alephant-sequencer-1.2.0

- old
+ new

@@ -32,9 +32,10 @@ block.call if (sequential || keep_all) if sequential set_last_seen(msg, last_seen_id) else + logger.metric(:name => "SequencerNonSequentialMessageCount", :unit => "Count", :value => 1) logger.info("Sequencer#sequence nonsequential message for #{ident} (last_seen_id: #{last_seen_id})") end end def delete!