lib/alephant/publisher/queue/sqs_helper/archiver.rb in alephant-publisher-queue-2.4.2 vs lib/alephant/publisher/queue/sqs_helper/archiver.rb in alephant-publisher-queue-2.5.0

@@ -7,14 +7,14 @@
     module Queue
       module SQSHelper
         class Archiver
           include Alephant::Logger
 
-          attr_reader :cache, :async, :log_message_body, :log_validator
+          attr_reader :storage, :async, :log_message_body, :log_validator
 
-          def initialize(cache, opts)
-            @cache            = cache
+          def initialize(storage, opts)
+            @storage          = storage
             @async            = opts[:async_store]
             @log_message_body = opts[:log_archive_message]
             @log_validator    = opts[:log_validator] || -> _ { true }
           end
 
@@ -49,17 +49,17 @@
               ) if log_validator.call(msg_body)
             end
           end
 
           def store_item(message)
-            cache.put(
-              cache_key(message.id),
+            storage.put(
+              storage_key(message.id),
               message.body,
               meta_for(message)
             )
           end
 
-          def cache_key(id)
+          def storage_key(id)
             "archive/#{date_key}/#{id}"
           end
 
           def log_message_parts(id)
             [