lib/alephant/publisher/writer.rb in alephant-publisher-0.2.3 vs lib/alephant/publisher/writer.rb in alephant-publisher-0.2.4

@@ -74,10 +74,15 @@
       def batch?
         !batch.nil?
       end
 
       def seq_for(id)
-        Sequencer.create(config[:sequencer_table_name], seq_key_from(id), config[:sequence_id_path])
+        Sequencer.create(
+          config[:sequencer_table_name],
+          seq_key_from(id),
+          config[:sequence_id_path],
+          config[:keep_all_messages] == 'true'
+        )
       end
 
       def seq_key_from(id)
         "#{id}/#{opt_hash}"
       end