lib/alephant/publisher/queue/options.rb in alephant-publisher-queue-1.0.0 vs lib/alephant/publisher/queue/options.rb in alephant-publisher-queue-1.1.0

@@ -5,10 +5,12 @@
   module Publisher
     module Queue
       class InvalidKeySpecifiedError < StandardError; end
 
       class Options
+        include Logger
+
         attr_reader :queue, :writer
 
         QUEUE_OPTS = [
           :receive_wait_time,
           :sqs_queue_name,
@@ -45,9 +47,10 @@
         def execute(instance, type, opts)
           begin
             validate type, opts
             instance.merge! opts
           rescue Exception => e
+            logger.metric(:name => "PublisherQueueInvalidKeySpecifiedError", :unit => "Count", :value => 1)
             puts e.message
           end
         end
 
         def validate(type, opts)