lib/alephant/sequencer/sequencer.rb in alephant-sequencer-0.3.0 vs lib/alephant/sequencer/sequencer.rb in alephant-sequencer-1.0.0

- old
+ new

@@ -23,10 +23,10 @@ def exists? @exists || @sequence_table.sequence_exists(ident) end - def sequence(msg, &block) + def validate(msg, &block) last_seen_id = get_last_seen sequential = ((last_seen_id || 0) < Sequencer.sequence_id_from(msg, jsonpath)) block.call(msg) if (sequential || keep_all)