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

- old
+ new

@@ -190,15 +190,10 @@ 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', @@ -211,14 +206,9 @@ 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).