lib/alephant/publisher/queue.rb in alephant-publisher-queue-2.1.0 vs lib/alephant/publisher/queue.rb in alephant-publisher-queue-2.1.1

@@ -46,11 +46,12 @@
           SQSHelper::Archiver.new(archive_cache, archiver_opts)
         end
 
         def archiver_opts
           options = {
+            :async_store         => true,
             :log_archive_message => true,
-            :async_store         => true
+            :log_validator       => opts.queue[:log_validator]
           }
           options.each do |key, _value|
             options[key] = opts.queue[key] == "true" if opts.queue.has_key? key
           end
         end