lib/alephant/publisher/queue/options.rb in alephant-publisher-queue-2.3.1 vs lib/alephant/publisher/queue/options.rb in alephant-publisher-queue-2.4.0

@@ -7,63 +7,72 @@
       class InvalidKeySpecifiedError < StandardError; end
 
       class Options
         include Alephant::Logger
 
-        attr_reader :queue, :writer
+        attr_reader :queue, :writer, :cache
 
         QUEUE_OPTS = [
           :receive_wait_time,
           :sqs_queue_name,
           :visibility_timeout,
           :aws_account_id,
           :sqs_account_region,
           :log_archive_message,
           :log_validator,
           :async_store
-        ]
+        ].freeze
 
         WRITER_OPTS = [
           :lookup_table_name,
           :msg_vary_id_path,
           :renderer_id,
           :s3_bucket_id,
           :s3_object_path,
           :sequence_id_path,
           :sequencer_table_name,
           :view_path
-        ]
+        ].freeze
 
+        CACHE_OPTS = [
+          :elasticache_config_endpoint,
+          :elasticache_cache_version,
+          :revalidate_cache_ttl
+        ].freeze
+
         def initialize
           @queue  = {}
           @writer = {}
+          @cache  = {}
         end
 
         def add_queue(opts)
-          execute @queue, QUEUE_OPTS, opts
+          execute(@queue, QUEUE_OPTS, opts)
         end
 
         def add_writer(opts)
-          execute @writer, WRITER_OPTS, opts
+          execute(@writer, WRITER_OPTS, opts)
         end
 
+        def add_cache(opts)
+          execute(@cache, CACHE_OPTS, opts)
+        end
+
         private
 
         def execute(instance, type, opts)
-          begin
-            validate type, opts
-            instance.merge! opts
-          rescue InvalidKeySpecifiedError => e
-            logger.metric "QueueOptionsInvalidKeySpecified"
-            logger.error(
-              "event"     => "QueueOptionsKeyInvalid",
-              "class"     => e.class,
-              "message"   => e.message,
-              "backtrace" => e.backtrace.join.to_s,
-              "method"    => "#{self.class}#validate"
-            )
-            puts e.message
-          end
+          validate(type, opts)
+          instance.merge!(opts)
+        rescue InvalidKeySpecifiedError => e
+          logger.metric "QueueOptionsInvalidKeySpecified"
+          logger.error(
+            "event"     => "QueueOptionsKeyInvalid",
+            "class"     => e.class,
+            "message"   => e.message,
+            "backtrace" => e.backtrace.join.to_s,
+            "method"    => "#{self.class}#validate"
+          )
+          puts e.message
         end
 
         def validate(type, opts)
           opts.each do |key, _value|
             unless type.include? key.to_sym