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

@@ -51,11 +51,15 @@
             :async_store         => true,
             :log_archive_message => true,
             :log_validator       => opts.queue[:log_validator]
           }
           options.each do |key, _value|
-            options[key] = opts.queue[key] == "true" if opts.queue.has_key? key
+            options[key] = opts.queue[key] == "true" if whitelist_key(opts.queue, key)
           end
+        end
+
+        def whitelist_key(options, key)
+          options.has_key?(key) && key != :log_validator
         end
 
         def archive_cache
           Cache.new(
             opts.writer[:s3_bucket_id],