lib/alephant/publisher/queue/sqs_helper/queue.rb in alephant-publisher-queue-1.2.2 vs lib/alephant/publisher/queue/sqs_helper/queue.rb in alephant-publisher-queue-1.3.2

@@ -27,9 +27,10 @@
           end
 
           private
 
           def process(m)
+            logger.metric(:name => "PublisherQueueSQSHelperMessagesReceived", :unit => "Count", :value => 1)
             logger.info("Queue#message: received #{m.id}")
             archive m
           end
 
           def archive(m)