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)