lib/alephant/publisher/queue/sqs_helper/queue.rb in alephant-publisher-queue-1.3.5 vs lib/alephant/publisher/queue/sqs_helper/queue.rb in alephant-publisher-queue-1.3.6

@@ -27,41 +27,26 @@
           end
 
           private
 
           def process(m)
-            logger.metric(
-              "MessagesReceived",
-              opts[:dimensions].merge(:function => "process")
-            )
+            logger.metric "MessagesReceived"
             logger.info("Queue#message: received #{m.id}")
             archive m
           end
 
           def archive(m)
             archiver.see(m) unless archiver.nil?
           rescue StandardError => e
-            logger.metric(
-              "ArchiveFailed",
-              opts[:dimensions].merge(:function => "archive")
-            )
+            logger.metric "ArchiveFailed"
             logger.warn("Queue#archive: archive failed (#{e.message})");
           end
 
           def receive
             queue.receive_message({
               :visibility_timeout => timeout,
               :wait_time_seconds  => wait_time
             })
-          end
-
-          def opts
-            {
-              :dimensions => {
-                :module   => "PublisherQueueSQSHelper",
-                :class    => "Queue"
-              }
-            }
           end
         end
       end
     end
   end