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!