lib/alephant/publisher/queue/options.rb in alephant-publisher-queue-1.2.2 vs lib/alephant/publisher/queue/options.rb in alephant-publisher-queue-1.3.2
- old
+ new
@@ -47,10 +47,11 @@
def execute(instance, type, opts)
begin
validate type, opts
instance.merge! opts
rescue Exception => e
- logger.warn "Publisher::Queue::Options#validate: '#{e.message}'"
+ logger.metric(:name => "PublisherQueueOptionsInvalidKeySpecified", :unit => "Count", :value => 1)
+ logger.error "Publisher::Queue::Options#validate: '#{e.message}'"
puts e.message
end
end
def validate(type, opts)