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).