lib/alephant/publisher/queue/sqs_helper/queue.rb in alephant-publisher-queue-1.0.0 vs lib/alephant/publisher/queue/sqs_helper/queue.rb in alephant-publisher-queue-1.1.0
- old
+ new
@@ -34,9 +34,10 @@
end
def archive(m)
archiver.see(m) unless archiver.nil?
rescue StandardError => e
+ logger.metric(:name => "PublisherQueueSQSHelperArchiveFailed", :unit => "Count", :value => 1)
logger.warn("Queue#archive: archive failed (#{e.message})");
end
def receive
queue.receive_message({