spec/utils/db_producer_spec.rb in deimos-ruby-1.3.0.pre.beta4 vs spec/utils/db_producer_spec.rb in deimos-ruby-1.3.0.pre.beta5

@@ -190,10 +190,15 @@
                                                                       key: nil,
                                                                       partition_key: 'key2',
                                                                       topic: 'my-topic'
                                                                     }
                                                                   ])
+      expect(Deimos.config.metrics).to receive(:increment).ordered.with(
+        'db_producer.process',
+        tags: %w(topic:my-topic),
+        by: 2
+      )
       expect(producer).to receive(:retrieve_messages).ordered.
         and_return(messages[2..3])
       expect(producer).to receive(:produce_messages).ordered.with([
                                                                     {
                                                                       payload: 'mess3',
@@ -206,9 +211,14 @@
                                                                       partition_key: 'key4',
                                                                       key: nil,
                                                                       topic: 'my-topic'
                                                                     }
                                                                   ])
+      expect(Deimos.config.metrics).to receive(:increment).ordered.with(
+        'db_producer.process',
+        tags: %w(topic:my-topic),
+        by: 2
+      )
       expect(producer).to receive(:retrieve_messages).ordered.
         and_return([])
       expect(Deimos::KafkaTopicInfo).to receive(:heartbeat).
         with('my-topic', 'abc').twice
       expect(Deimos::KafkaTopicInfo).to receive(:clear_lock).