lib/alephant/publisher/queue.rb in alephant-publisher-queue-1.3.6 vs lib/alephant/publisher/queue.rb in alephant-publisher-queue-1.4.0

@@ -41,10 +41,20 @@
         end
 
         private
 
         def archiver
-          SQSHelper::Archiver.new(archive_cache)
+          SQSHelper::Archiver.new(archive_cache, archiver_opts)
+        end
+
+        def archiver_opts
+          options = {
+            :log_archive_message => true,
+            :async_store         => true
+          }
+          options.each do |key, value|
+            options[key] = opts.queue[key] == "true" if opts.queue.has_key? key
+          end
         end
 
         def archive_cache
           Cache.new(
             opts.writer[:s3_bucket_id],